diff --git a/cloud-task-server/src/main/java/com/muyu/service/impl/TaskServiceImpl.java b/cloud-task-server/src/main/java/com/muyu/service/impl/TaskServiceImpl.java index 5b1a32b..ddd0a50 100644 --- a/cloud-task-server/src/main/java/com/muyu/service/impl/TaskServiceImpl.java +++ b/cloud-task-server/src/main/java/com/muyu/service/impl/TaskServiceImpl.java @@ -228,7 +228,7 @@ public class TaskServiceImpl extends ServiceImpl implement private void selectAndAdd(Integer count,Long databaseId,Long basicId,String sql,Long tableId, HashMap newAndOldMap,Integer two) { - int pageSize = 10000; + int pageSize = 700000; long firstArray = 0L; int totalSegments = (int) Math.ceil((double) count / pageSize); for (int i = 0; i < totalSegments; i++) { @@ -253,7 +253,6 @@ public class TaskServiceImpl extends ServiceImpl implement Result result = dataValueClient.addProduct(basicId, tableId, tableValue); log.info("添加结果为{}", result); log.info("添加到queue里成功"); - }