AE86 преди 3 месеца
родител
ревизия
92aa911bc8
променени са 1 файла, в които са добавени 1 реда и са изтрити 1 реда
  1. 1 1
      dbsyncer-parser/src/main/java/org/dbsyncer/parser/impl/ParserComponentImpl.java

+ 1 - 1
dbsyncer-parser/src/main/java/org/dbsyncer/parser/impl/ParserComponentImpl.java

@@ -203,7 +203,7 @@ public class ParserComponentImpl implements ParserComponent {
             pluginFactory.process(group.getPlugin(), context, ProcessEnum.AFTER);
 
             // 8、判断尾页
-            if (source.size() < context.getPageIndex()) {
+            if (source.size() < context.getPageSize()) {
                 logger.info("完成全量:{}, [{}] >> [{}]", metaId, sTableName, tTableName);
                 break;
             }