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 0625d5d..8c36f63 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 @@ -202,7 +202,9 @@ public class TaskServiceImpl extends ServiceImpl implement } String limitSelect = sql + limit; SegmentTask segmentTask = new SegmentTask(limitSelect, tableId, basicId,newAndOldMap, Weight.getWeight(weigh)); + log.info("创建任务添加到队列当中"); queue.add(segmentTask); + log.info("添加到queue里成功"); } // 启动线程池执行任务 diff --git a/cloud-task-server/src/main/java/com/muyu/task/SegmentTask.java b/cloud-task-server/src/main/java/com/muyu/task/SegmentTask.java index b3ce62a..7327183 100644 --- a/cloud-task-server/src/main/java/com/muyu/task/SegmentTask.java +++ b/cloud-task-server/src/main/java/com/muyu/task/SegmentTask.java @@ -42,6 +42,8 @@ public class SegmentTask implements Runnable, Comparable { @Override public void run() { + + log.info("开始执行任务:" + basicId + " " + sql + " " + weight + " " + tableId, tableId); // 查询数据 Result>> tableValue = dataValueClient.findTableValue(basicId, sql); List> data = tableValue.getData();