From d675c288122d0048a6d5f14ff392dbf5799411bd Mon Sep 17 00:00:00 2001 From: "changxiangshimian/changxiangshimian.github.io" <1422234316@qq.com> Date: Fri, 31 May 2024 09:22:26 +0800 Subject: [PATCH] Update WorkflowExecuteRunnable.java (#16092) Corrected the following issues https://github.com/apache/dolphinscheduler/issues/15366 https://github.com/apache/dolphinscheduler/issues/16010 --- .../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 7c27e8c985..c35fd9991f 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 @@ -639,6 +639,7 @@ public class WorkflowExecuteRunnable implements IWorkflowExecuteRunnable { command.setProcessInstanceId(0); command.setProcessDefinitionVersion(workflowInstance.getProcessDefinitionVersion()); command.setTestFlag(workflowInstance.getTestFlag()); + command.setTenantCode(workflowInstance.getTenantCode()); int create = commandService.createCommand(command); processService.saveCommandTrigger(command.getId(), workflowInstance.getId()); return create;