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

修改超时时间

master
Cui YongXing 2024-09-10 16:07:33 +08:00
parent 3579288fad
commit d155d61ea5
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

@ -397,6 +397,7 @@ 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()); log.info("className:{}",data.getClassName());