Fix task instance which status is dispatch will not be failover (apache#16107)

ruanwenjun · web-flow · commit 5867bee95d27 · 2024-06-05T11:33:41.000+08:00
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
@@ -1219,12 +1219,12 @@ private void submitPostNode(Long parentNodeCode) throws StateEventHandleExceptio
                         || state == TaskExecutionStatus.DISPATCH
                         || state == TaskExecutionStatus.SUBMITTED_SUCCESS
                         || state == TaskExecutionStatus.DELAY_EXECUTION) {
-                    // try to take over task instance
-                    if (state == TaskExecutionStatus.SUBMITTED_SUCCESS || state == TaskExecutionStatus.DELAY_EXECUTION
-                            || state == TaskExecutionStatus.DISPATCH) {
+                    if (state == TaskExecutionStatus.SUBMITTED_SUCCESS
+                            || state == TaskExecutionStatus.DELAY_EXECUTION) {
                         // The taskInstance is not in running, directly takeover it
                     } else if (tryToTakeOverTaskInstance(existTaskInstance)) {
-                        log.info("Success take over task {}", existTaskInstance.getName());
+                        // If the taskInstance has already dispatched to worker then will try to take-over it
+                        log.info("Success take over task {} -> status: {}", existTaskInstance.getName(), state);
                         continue;
                     } else {
                         // set the task instance state to fault tolerance
