From 533c5cb8f6bda878779fffb1a4adc792f62a81a7 Mon Sep 17 00:00:00 2001 From: agapple Date: Tue, 5 Apr 2016 23:42:08 +0800 Subject: [PATCH] fixed issue #119 , fixed batch data changeColumns --- .../canal/parse/inbound/mysql/dbsync/LogEventConvert.java | 4 ++-- 1 file changed, 2 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 37ea0d00..e066dd96 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 @@ -350,7 +350,7 @@ public class LogEventConvert extends AbstractCanalLifeCycle implements BinlogPar rowChangeBuider.setEventType(eventType); RowsLogBuffer buffer = event.getRowsBuf(charset.name()); BitSet columns = event.getColumns(); - BitSet changeColumns = event.getColumns(); + BitSet changeColumns = event.getChangeColumns(); boolean tableError = false; TableMeta tableMeta = null; if (tableMetaCache != null) {// 入错存在table meta cache @@ -380,7 +380,7 @@ public class LogEventConvert extends AbstractCanalLifeCycle implements BinlogPar break; } - tableError |= parseOneRow(rowDataBuilder, event, buffer, event.getChangeColumns(), true, tableMeta); + tableError |= parseOneRow(rowDataBuilder, event, buffer, changeColumns, true, tableMeta); } rowChangeBuider.addRowDatas(rowDataBuilder.build());