etl
/
cloud-etl-task
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

修改超时时间

master
Cui YongXing 2024-09-10 15:53:42 +08:00
parent a48c84134a
commit 3579288fad
1 changed files with 1 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
cloud-task-server/src/main/java/com/muyu/task/server/service/impl/TaskInfoServiceImpl.java
View File

@ -399,6 +399,7 @@ public class TaskInfoServiceImpl extends ServiceImpl<TaskInfoMapper, TaskInfo> i
for (NodeRule nodeRule : list) { for (NodeRule nodeRule : list) {
Result<RuleEngineVersion> result = ruleConfig.findVersionById(nodeRule.getRuleId()); Result<RuleEngineVersion> result = ruleConfig.findVersionById(nodeRule.getRuleId());
RuleEngineVersion data = result.getData(); RuleEngineVersion data = result.getData();
log.info("className:{}",data.getClassName());
final Future<DataValue[][]> finalCurrentFuture = currentFuture; final Future<DataValue[][]> finalCurrentFuture = currentFuture;
log.info(finalCurrentFuture); log.info(finalCurrentFuture);
Callable<DataValue[][]> task = () -> { Callable<DataValue[][]> task = () -> {