Browse Source

[Fix-8506][Master] process instance stop result wrong (#8529)

* fix bug_8506

* recover success state
3.0.0/version-upgrade
xiangzihao 3 years ago committed by GitHub
parent
commit
74afdcf8f3
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
  1. 6
      dolphinscheduler-master/src/main/java/org/apache/dolphinscheduler/server/master/runner/WorkflowExecuteThread.java

6
dolphinscheduler-master/src/main/java/org/apache/dolphinscheduler/server/master/runner/WorkflowExecuteThread.java

@ -415,6 +415,9 @@ public class WorkflowExecuteThread {
iTaskProcessor.action(TaskAction.RUN); iTaskProcessor.action(TaskAction.RUN);
if (iTaskProcessor.taskInstance().getState().typeIsFinished()) { if (iTaskProcessor.taskInstance().getState().typeIsFinished()) {
if (iTaskProcessor.taskInstance().getState() != task.getState()) {
task.setState(iTaskProcessor.taskInstance().getState());
}
taskFinished(task); taskFinished(task);
} }
return true; return true;
@ -455,7 +458,10 @@ public class WorkflowExecuteThread {
killAllTasks(); killAllTasks();
} }
} }
} else if (taskInstance.getState().typeIsFinished()) {
completeTaskMap.put(taskInstance.getTaskCode(), taskInstance.getId());
} }
this.updateProcessInstanceState(); this.updateProcessInstanceState();
} }

Loading…
Cancel
Save