[dolphinscheduler] branch dev updated: Update WorkflowExecuteRunnable.java (#13155)

[caishunfeng]

This is an automated email from the ASF dual-hosted git repository.

caishunfeng pushed a commit to branch dev
in repository https://gitbox.apache.org/repos/asf/dolphinscheduler.git


The following commit(s) were added to refs/heads/dev by this push:
     new d64004abea Update WorkflowExecuteRunnable.java (#13155)
d64004abea is described below

commit d64004abea8cd18fbfe39437d25497bd8f1dfa27
Author: ititdog <49965805+itit...@users.noreply.github.com>
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 344f113e27..b5d8ed3356 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
@@ -445,13 +445,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();
                     }