Browse Source

[Fix-9975] The selected task instance was recreated when the Master service fail… (#9976)

* The selected task instance was recreated when the Master service failed over.

* Returns the expression result directly.

* Use Recovery to determine whether to use the old task instance.

(cherry picked from commit dbdbfeaeee)
3.0.0/version-upgrade
WangJPLeo 3 years ago committed by Jiajie Zhong
parent
commit
7b0e6fe5ec
  1. 3
      dolphinscheduler-master/src/main/java/org/apache/dolphinscheduler/server/master/runner/WorkflowExecuteThread.java

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

@ -1960,6 +1960,9 @@ public class WorkflowExecuteThread {
private boolean isNewProcessInstance() { private boolean isNewProcessInstance() {
if (ExecutionStatus.RUNNING_EXECUTION == processInstance.getState() && processInstance.getRunTimes() == 1) { if (ExecutionStatus.RUNNING_EXECUTION == processInstance.getState() && processInstance.getRunTimes() == 1) {
return true; return true;
} else if (processInstance.getRecovery().equals(Flag.YES)) {
// host is empty use old task instance
return false;
} else { } else {
return false; return false;
} }

Loading…
Cancel
Save