|
@@ -113,8 +113,7 @@ public final class FullPuller extends AbstractPuller implements ApplicationListe
|
|
Map<String, String> snapshot = meta.getSnapshot();
|
|
Map<String, String> snapshot = meta.getSnapshot();
|
|
task.setPageIndex(NumberUtil.toInt(snapshot.get(ParserEnum.PAGE_INDEX.getCode()), ParserEnum.PAGE_INDEX.getDefaultValue()));
|
|
task.setPageIndex(NumberUtil.toInt(snapshot.get(ParserEnum.PAGE_INDEX.getCode()), ParserEnum.PAGE_INDEX.getDefaultValue()));
|
|
// 反序列化游标值类型(通常为数字或字符串类型)
|
|
// 反序列化游标值类型(通常为数字或字符串类型)
|
|
- String cursorValue = snapshot.get(ParserEnum.CURSOR.getCode());
|
|
|
|
- task.setCursors(PrimaryKeyUtil.getLastCursors(cursorValue));
|
|
|
|
|
|
+ task.setCursors(PrimaryKeyUtil.getLastCursors(snapshot.get(ParserEnum.CURSOR.getCode())));
|
|
task.setTableGroupIndex(NumberUtil.toInt(snapshot.get(ParserEnum.TABLE_GROUP_INDEX.getCode()), ParserEnum.TABLE_GROUP_INDEX.getDefaultValue()));
|
|
task.setTableGroupIndex(NumberUtil.toInt(snapshot.get(ParserEnum.TABLE_GROUP_INDEX.getCode()), ParserEnum.TABLE_GROUP_INDEX.getDefaultValue()));
|
|
flush(task);
|
|
flush(task);
|
|
|
|
|