Signed-off-by: AE86 <836391306@qq.com>
@@ -215,7 +215,8 @@ public class MappingServiceImpl extends BaseServiceImpl implements MappingServic
Meta meta = manager.getMeta(metaId);
Assert.notNull(meta, "Mapping meta can not be null.");
if (meta.getTotal().get() >= (meta.getSuccess().get() + meta.getFail().get())) {
- meta.clear();
+ meta.getFail().set(0);
+ meta.getSuccess().set(0);
manager.editMeta(meta);
}
@@ -116,8 +116,6 @@ public class FullPuller extends AbstractPuller implements ApplicationListener<Fu
// 记录结束时间
task.setEndTime(Instant.now().toEpochMilli());
- task.setPageIndex(ParserEnum.PAGE_INDEX.getDefaultValue());
- task.setCursor("");
task.setTableGroupIndex(ParserEnum.TABLE_GROUP_INDEX.getDefaultValue());
flush(task);