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; };