natas_hw
/
dolphinscheduler
0
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

[Fix-10443][server]fix dependent task always running (#10708) 

* [Fix-10443][server]fix dependent task always running

* optimize remove logic
This commit is contained in:
weeway 2022-07-01 17:21:26 +08:00 committed by GitHub
parent 85d3637f9d
commit 520e72f3de
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 2 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
dolphinscheduler-server/src/main/java/org/apache/dolphinscheduler/server/master/runner/WorkflowExecuteThread.java
View File

@ -1430,10 +1430,9 @@ public class WorkflowExecuteThread implements Runnable {
this.processInstance.getId()); this.processInstance.getId());
taskResponseService.addResponse(taskResponseEvent); taskResponseService.addResponse(taskResponseEvent);
} }
this.taskRetryCheckList.remove(taskId);
this.depStateCheckList.remove(taskId);
} }
this.taskRetryCheckList.clear();
this.depStateCheckList.clear();
this.addProcessStopEvent(processInstance); this.addProcessStopEvent(processInstance);
} }