From 72ceb58fa3e0e484ca27cdfc7fd5f20cd0277561 Mon Sep 17 00:00:00 2001 From: agapple Date: Wed, 2 Dec 2015 14:37:06 +0800 Subject: [PATCH] fixed issue #135 , isUpdate bugfix --- .../canal/parse/inbound/mysql/dbsync/LogEventConvert.java | 5 +++-- 1 file changed, 3 insertions(+), 2 deletions(-) diff --git a/parse/src/main/java/com/alibaba/otter/canal/parse/inbound/mysql/dbsync/LogEventConvert.java b/parse/src/main/java/com/alibaba/otter/canal/parse/inbound/mysql/dbsync/LogEventConvert.java index 603f4543..cc092d46 100644 --- a/parse/src/main/java/com/alibaba/otter/canal/parse/inbound/mysql/dbsync/LogEventConvert.java +++ b/parse/src/main/java/com/alibaba/otter/canal/parse/inbound/mysql/dbsync/LogEventConvert.java @@ -623,8 +623,9 @@ public class LogEventConvert extends AbstractCanalLifeCycle implements BinlogPar if (column.getIsNull() && newValue == null) { // 如果全是null return false; - } else if (newValue != null && column.getValue().equals(newValue)) { - // 如果不围null,并且相等 + } else if (newValue != null && (!column.getIsNull() && column.getValue().equals(newValue))) { + // fixed issue #135, old column is Null + // 如果不为null,并且相等 return false; } }