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 07bde4479c44..98d267383da0 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 @@ -1936,6 +1936,7 @@ public void submitStandByTask() throws StateEventHandleException { log.info("The dependResult of task {} is success, so ready to submit to execute", task.getName()); Optional taskInstanceOptional = submitTaskExec(task); if (!taskInstanceOptional.isPresent()) { + task.setId(0); this.taskFailedSubmit = true; // Remove and add to complete map and error map if (!removeTaskFromStandbyList(task)) {