From 2950c9a577bbb0f5ad6fb94d5eb31a176959075c Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E9=99=88=E6=80=9D=E8=B1=AA?= <1437200870@qq.com> Date: Fri, 6 Sep 2024 19:01:08 +0800 Subject: [PATCH] =?UTF-8?q?=E6=B7=BB=E5=8A=A0=E8=81=94=E6=9F=A5=E4=BF=A1?= =?UTF-8?q?=E6=81=AF=E6=96=B9=E6=B3=95?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../src/main/java/com/muyu/service/impl/TaskServiceImpl.java | 1 + .../src/main/java/com/muyu/task/SegmentTask.java | 4 ++-- 2 files changed, 3 insertions(+), 2 deletions(-) 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();