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

修改超时时间

master
Cui YongXing 2024-09-10 16:19:35 +08:00
parent 99da2f8015
commit 04449e4c41
1 changed files with 7 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -401,17 +401,23 @@ public class TaskInfoServiceImpl extends ServiceImpl<TaskInfoMapper, TaskInfo> i
Result<RuleEngineVersion> result = ruleConfig.findVersionById(nodeRule.getRuleId()); Result<RuleEngineVersion> result = ruleConfig.findVersionById(nodeRule.getRuleId());
RuleEngineVersion data = result.getData(); RuleEngineVersion data = result.getData();
final Future<DataValue[][]> finalCurrentFuture = currentFuture; final Future<DataValue[][]> finalCurrentFuture = currentFuture;
log.info(finalCurrentFuture); // log.info(finalCurrentFuture);
Callable<DataValue[][]> task = () -> { Callable<DataValue[][]> task = () -> {
DataValue[][] prevResult = finalCurrentFuture.get(); DataValue[][] prevResult = finalCurrentFuture.get();
HashSet<Integer> set = new HashSet<>(); HashSet<Integer> set = new HashSet<>();
//log.info(data.getClassName()); //log.info(data.getClassName());
if (data.getRuleId().equals("3")) { if (data.getRuleId().equals("3")) {
log.info("1");
DataValueRows dataValueRows = new DataValueRows(); DataValueRows dataValueRows = new DataValueRows();
log.info("2");
dataValueRows.setDataValue(prevResult); dataValueRows.setDataValue(prevResult);
log.info("3");
dataValueRows.setKey(nodeRule.getConfig()); dataValueRows.setKey(nodeRule.getConfig());
log.info("4");
Result<DataValue[][]> result1 = ruleConfig.DataSetEngine(data.getClassName(), dataValueRows); Result<DataValue[][]> result1 = ruleConfig.DataSetEngine(data.getClassName(), dataValueRows);
log.info("5");
if (result1.getCode() == 200) { if (result1.getCode() == 200) {
log.info("6");
prevResult = result1.getData(); prevResult = result1.getData();
} }
} }