This is an automated email from the ASF dual-hosted git repository. zhongjiajie pushed a commit to branch 3.0.5-prepare in repository https://gitbox.apache.org/repos/asf/dolphinscheduler.git
commit 33f2cafdb06c3c06e245da64feba2de4b1b1d902 Author: ititdog <[email protected]> AuthorDate: Thu Mar 30 15:12:40 2023 +0800 Update WorkflowExecuteRunnable.java (#13155) (cherry picked from commit d64004abea8cd18fbfe39437d25497bd8f1dfa27) --- .../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 6af96d1630..d5a09f9d53 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 @@ -383,13 +383,13 @@ public class WorkflowExecuteRunnable implements Callable<WorkflowSubmitStatue> { retryTaskInstance(taskInstance); } else if (taskInstance.getState().typeIsFailure()) { 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(); }
