From d617620b006add58bc34989d40ce62ec891e2bf7 Mon Sep 17 00:00:00 2001 From: fuchanghai <33984497+fuchanghai@users.noreply.github.com> Date: Fri, 21 Apr 2023 15:49:43 +0800 Subject: [PATCH] [improve-#13956] taskId is null (#13980) MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit Co-authored-by: fuchanghai <‘2875334588@qq.com’> --- .../server/master/runner/WorkflowExecuteRunnable.java | 1 + 1 file changed, 1 insertion(+) 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 07bde4479c..98d267383d 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 class WorkflowExecuteRunnable implements Callable { 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)) {