gtsoft/gtsoft-snail-job-server
1
0
Fork 0
Code Issues Pull Requests 1 Actions Packages Projects 1 Releases Wiki Activity

fix:(1.2.0-beta2): 1、修复MapReduce模式Reduce、MergeReduce阶段异常更新工作流上下文 2、去除工作流节点stop相关重复代码

Browse Source
This commit is contained in:
srzou 2024-10-08 10:38:15 +08:00
parent 399ed8298d
commit 7271eb8ee2
2 changed files with 8 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
snail-job-server/snail-job-server-job-task/src/main/java/com/aizuda/snailjob/server/job/task/support/result/job/MapReduceJobExecutorHandler.java
View File

@ -123,4 +123,12 @@ public class MapReduceJobExecutorHandler extends AbstractJobExecutorResultHandle
return false;
}
@Override
protected void openNextWorkflowNode(JobExecutorResultContext context) {
if (context.isCreateReduceTask()){
// 任务暂未完成，无需开启后续节点；更新上下文
return;
}
super.openNextWorkflowNode(context);
}
}

8
snail-job-server/snail-job-server-web/src/main/java/com/aizuda/snailjob/server/web/service/impl/WorkflowNodeServiceImpl.java
View File

@ -52,14 +52,6 @@ public class WorkflowNodeServiceImpl implements WorkflowNodeService {
jobHandler.stop(jobTaskBatch.getId());
}
// 继续执行后续的任务
WorkflowNodeTaskExecuteDTO taskExecuteDTO = new WorkflowNodeTaskExecuteDTO();
taskExecuteDTO.setWorkflowTaskBatchId(workflowTaskBatchId);
taskExecuteDTO.setTaskExecutorScene(JobTaskExecutorSceneEnum.MANUAL_WORKFLOW.getType());
taskExecuteDTO.setParentId(nodeId);
workflowBatchHandler.openNextNode(taskExecuteDTO);
return Boolean.TRUE;
}