From 75f4fa288176c5466db69381bd5b62413b31e945 Mon Sep 17 00:00:00 2001 From: Kerwin <37063904+zhuangchong@users.noreply.github.com> Date: Mon, 12 Jun 2023 19:40:26 +0800 Subject: [PATCH] Fix the complement function does not generate the next running instances in parallel mode (#14335) --- .../server/master/runner/WorkflowExecuteRunnable.java | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) 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 4258b672dc..1564adbc14 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 @@ -732,8 +732,9 @@ public class WorkflowExecuteRunnable implements Callable { command.setProcessInstanceId(0); command.setProcessDefinitionVersion(processInstance.getProcessDefinitionVersion()); command.setTestFlag(processInstance.getTestFlag()); + int create = commandService.createCommand(command); processService.saveCommandTrigger(command.getId(), processInstance.getId()); - return commandService.createCommand(command); + return create; } private boolean needComplementProcess() {