Update WorkflowExecuteRunnable.java (#13155)

(cherry picked from commit d64004a)
apache · Mar 30, 2023 · 33f2caf · 33f2caf
1 parent a7fc67f
commit 33f2caf
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/...c/main/java/org/apache/dolphinscheduler/server/master/runner/WorkflowExecuteRunnable.java b/...c/main/java/org/apache/dolphinscheduler/server/master/runner/WorkflowExecuteRunnable.java
@@ -383,13 +383,13 @@ public void taskFinished(TaskInstance taskInstance) throws StateEventHandleExcep
                 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();
                     }