From 99da2f8015197698e10a7eb11a73cdefd0e682ac Mon Sep 17 00:00:00 2001 From: Cui YongXing <2835316714@qq.com> Date: Tue, 10 Sep 2024 16:11:55 +0800 Subject: [PATCH] =?UTF-8?q?=E4=BF=AE=E6=94=B9=E8=B6=85=E6=97=B6=E6=97=B6?= =?UTF-8?q?=E9=97=B4?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../muyu/task/server/service/impl/TaskInfoServiceImpl.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/cloud-task-server/src/main/java/com/muyu/task/server/service/impl/TaskInfoServiceImpl.java b/cloud-task-server/src/main/java/com/muyu/task/server/service/impl/TaskInfoServiceImpl.java index 58b44b7..5146b42 100644 --- a/cloud-task-server/src/main/java/com/muyu/task/server/service/impl/TaskInfoServiceImpl.java +++ b/cloud-task-server/src/main/java/com/muyu/task/server/service/impl/TaskInfoServiceImpl.java @@ -397,10 +397,9 @@ public class TaskInfoServiceImpl extends ServiceImpl i Future currentFuture = executor.submit(tasks.poll()); if (!CollectionUtils.isEmpty(list)) { for (NodeRule nodeRule : list) { - log.info("============ {} +++++++" ,nodeRule.getRuleId()); + Result result = ruleConfig.findVersionById(nodeRule.getRuleId()); RuleEngineVersion data = result.getData(); - log.info("className:{}",data.getClassName()); final Future finalCurrentFuture = currentFuture; log.info(finalCurrentFuture); Callable task = () -> { @@ -452,6 +451,7 @@ public class TaskInfoServiceImpl extends ServiceImpl i List listArrays = Arrays.stream(prevResult).toList(); listArrays.removeAll(set); DataValue[][] array = (DataValue[][]) listArrays.toArray(); + log.info(array.toString()); return array; };