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 6623159..17f6b24 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 @@ -211,6 +211,7 @@ public class TaskServiceImpl extends ServiceImpl implement log.info("创建任务添加到队列当中"); queue.add(segmentTask); log.info("添加到queue里成功"); + break; } // 启动线程池执行任务 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 cf0a9bd..d44204e 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 @@ -47,9 +47,9 @@ public class SegmentTask implements Runnable, Comparable { log.info("开始执行任务:" + basicId + " " + sql + " " + weight + " " + tableId, tableId); // 查询数据 Result tableValue = dataValueClient.findTableValue(basicId, sql); - log.info("远程调用完毕,调用的值为{}",tableValue); + log.info("远程调用完毕,调用的值为{}",tableValue.getData()); List> data = (List>) tableValue.getData(); - log.info("查询结果:" + data); + log.info("查询结果:{}", data); for (List datum : data) { for (DataValue dataValue : datum) { String key = dataValue.getKey();