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

修改超时时间

master
Cui YongXing 2024-09-10 16:11:55 +08:00
parent d155d61ea5
commit 99da2f8015
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -397,10 +397,9 @@ public class TaskInfoServiceImpl extends ServiceImpl<TaskInfoMapper, TaskInfo> i
Future<DataValue[][]> currentFuture = executor.submit(tasks.poll()); Future<DataValue[][]> currentFuture = executor.submit(tasks.poll());
if (!CollectionUtils.isEmpty(list)) { if (!CollectionUtils.isEmpty(list)) {
for (NodeRule nodeRule : list) { for (NodeRule nodeRule : list) {
log.info("============ {} +++++++" ,nodeRule.getRuleId());
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 = () -> {
@ -452,6 +451,7 @@ public class TaskInfoServiceImpl extends ServiceImpl<TaskInfoMapper, TaskInfo> i
List<DataValue[]> listArrays = Arrays.stream(prevResult).toList(); List<DataValue[]> listArrays = Arrays.stream(prevResult).toList();
listArrays.removeAll(set); listArrays.removeAll(set);
DataValue[][] array = (DataValue[][]) listArrays.toArray(); DataValue[][] array = (DataValue[][]) listArrays.toArray();
log.info(array.toString());
return array; return array;
}; };