Browse Source

Fix the complement function does not generate the next running instances in parallel mode (#14335)

3.2.1-prepare
Kerwin 2 years ago committed by GitHub
parent
commit
75f4fa2881
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
  1. 3
      dolphinscheduler-master/src/main/java/org/apache/dolphinscheduler/server/master/runner/WorkflowExecuteRunnable.java

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

@ -732,8 +732,9 @@ public class WorkflowExecuteRunnable implements Callable<WorkflowSubmitStatus> {
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() {

Loading…
Cancel
Save