This is an automated email from the ASF dual-hosted git repository. kerwin pushed a commit to branch 3.1.5-prepare in repository https://gitbox.apache.org/repos/asf/dolphinscheduler.git
commit 68c8d5502f8281373d0ac92de411b8c275b15040 Author: ititdog <[email protected]> AuthorDate: Thu Mar 30 15:12:40 2023 +0800 Update WorkflowExecuteRunnable.java (#13155) --- .../dolphinscheduler/server/master/runner/WorkflowExecuteRunnable.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/dolphinscheduler-master/src/main/java/org/apache/dolphinscheduler/server/master/runner/WorkflowExecuteRunnable.java b/dolphinscheduler-master/src/main/java/org/apache/dolphinscheduler/server/master/runner/WorkflowExecuteRunnable.java index 4e3bd4d575..4cbfb3b826 100644 --- a/dolphinscheduler-master/src/main/java/org/apache/dolphinscheduler/server/master/runner/WorkflowExecuteRunnable.java +++ b/dolphinscheduler-master/src/main/java/org/apache/dolphinscheduler/server/master/runner/WorkflowExecuteRunnable.java @@ -404,13 +404,13 @@ public class WorkflowExecuteRunnable implements Callable<WorkflowSubmitStatue> { retryTaskInstance(taskInstance); } else if (taskInstance.getState().isFailure()) { completeTaskMap.put(taskInstance.getTaskCode(), taskInstance.getId()); - errorTaskMap.put(taskInstance.getTaskCode(), taskInstance.getId()); // There are child nodes and the failure policy is: CONTINUE if (processInstance.getFailureStrategy() == FailureStrategy.CONTINUE && DagHelper.haveAllNodeAfterNode( Long.toString(taskInstance.getTaskCode()), dag)) { submitPostNode(Long.toString(taskInstance.getTaskCode())); } else { + errorTaskMap.put(taskInstance.getTaskCode(), taskInstance.getId()); if (processInstance.getFailureStrategy() == FailureStrategy.END) { killAllTasks(); }
