Skip to content

Commit dbdbfea

Browse files
authored
[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.
1 parent 00f1029 commit dbdbfea

1 file changed

Lines changed: 3 additions & 0 deletions

File tree

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

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1960,6 +1960,9 @@ private boolean checkTaskQueue() {
19601960
private boolean isNewProcessInstance() {
19611961
if (ExecutionStatus.RUNNING_EXECUTION == processInstance.getState() && processInstance.getRunTimes() == 1) {
19621962
return true;
1963+
} else if (processInstance.getRecovery().equals(Flag.YES)) {
1964+
// host is empty use old task instance
1965+
return false;
19631966
} else {
19641967
return false;
19651968
}

0 commit comments

Comments
 (0)