Sfoglia il codice sorgente

修复未持久化记录

AE86 4 anni fa
parent
commit
5466df9400

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

@@ -195,7 +195,7 @@ public class IncrementPuller extends AbstractPuller implements ScheduledTaskJob,
         @Override
         public void forceFlushEvent(Map<String, String> map) {
             Meta meta = manager.getMeta(metaId);
-            if (null != meta && !CollectionUtils.isEmpty(map)) {
+            if (null != meta) {
                 meta.setMap(map);
                 manager.editMeta(meta);
             }