bugfix

dbsyncer-manager/src/main/java/org/dbsyncer/manager/puller/impl/IncrementPuller.java

@@ -295,9 +295,9 @@ public class IncrementPuller extends AbstractPuller implements ScheduledTaskJob,
 
         @Override
         public void changedLogEvent(RowChangedEvent rowChangedEvent) {
-            logger.info("监听数据=> tableName:{}, event:{}, before:{}, after:{}, rowId:{}", rowChangedEvent.getTableName(),
+            logger.info("监听数据=> tableName:{}, event:{}, beforeData:{}, afterData:{}, rowId:{}", rowChangedEvent.getTableName(),
                     rowChangedEvent.getEvent(),
-                    rowChangedEvent.getBefore(), rowChangedEvent.getAfter(), rowChangedEvent.getRowId());
+                    rowChangedEvent.getBeforeData(), rowChangedEvent.getAfterData(), rowChangedEvent.getRowId());
 
             // 处理过程有异常向上抛
             List<FieldPicker> pickers = tablePicker.get(rowChangedEvent.getTableName());

dbsyncer-parser/src/main/java/org/dbsyncer/parser/ParserFactory.java

@@ -240,7 +240,8 @@ public class ParserFactory implements Parser {
 
     @Override
     public void execute(Mapping mapping, TableGroup tableGroup, RowChangedEvent rowChangedEvent, PrimaryKeyMappingStrategy strategy) {
-        logger.info("{}", rowChangedEvent);
+        logger.info("解析数据=> tableName:{}, event:{}, before:{}, after:{}, rowId:{}", rowChangedEvent.getTableName(), rowChangedEvent.getEvent(),
+                rowChangedEvent.getBefore(), rowChangedEvent.getAfter(), rowChangedEvent.getRowId());
         final String metaId = mapping.getMetaId();
 
         ConnectorConfig tConfig = getConnectorConfig(mapping.getTargetConnectorId());

dbsyncer-parser/src/main/java/org/dbsyncer/parser/util/PickerUtil.java

@@ -83,14 +83,14 @@ public abstract class PickerUtil {
     }
 
     public static void pickData(Picker picker, Map<String, Object> row) {
+        Map<String, Object> target = new HashMap<>();
         if (!CollectionUtils.isEmpty(row)) {
-            Map<String, Object> target = new HashMap<>();
             List<Field> sFields = picker.getSourceFields();
             List<Field> tFields = picker.getTargetFields();
 
             exchange(sFields.size(), sFields, tFields, row, target);
-            picker.setTarget(target);
         }
+        picker.setTarget(target);
     }
 
     public static Map<String, Field> convert2Map(List<Field> col) {