This is an automated email from the ASF dual-hosted git repository. zhongjiajie pushed a commit to branch 3.0.3-prepare in repository https://gitbox.apache.org/repos/asf/dolphinscheduler.git
commit a28e206166a10010d36a5dc0d9e2fd54f799678b Author: Kerwin <[email protected]> AuthorDate: Tue Nov 22 15:35:29 2022 +0800 [Bug-12954] [Schedule] Fix that workflow-level configuration information does not take effect when timing triggers execution (#12955) (cherry picked from commit 2f8f0952fb6e45b84437e9f651096858d856bd96) --- .../org/apache/dolphinscheduler/service/quartz/ProcessScheduleJob.java | 1 + 1 file changed, 1 insertion(+) diff --git a/dolphinscheduler-service/src/main/java/org/apache/dolphinscheduler/service/quartz/ProcessScheduleJob.java b/dolphinscheduler-service/src/main/java/org/apache/dolphinscheduler/service/quartz/ProcessScheduleJob.java index d726840fa1..0904d1b25e 100644 --- a/dolphinscheduler-service/src/main/java/org/apache/dolphinscheduler/service/quartz/ProcessScheduleJob.java +++ b/dolphinscheduler-service/src/main/java/org/apache/dolphinscheduler/service/quartz/ProcessScheduleJob.java @@ -91,6 +91,7 @@ public class ProcessScheduleJob extends QuartzJobBean { command.setWarningGroupId(schedule.getWarningGroupId()); String workerGroup = StringUtils.isEmpty(schedule.getWorkerGroup()) ? Constants.DEFAULT_WORKER_GROUP : schedule.getWorkerGroup(); command.setWorkerGroup(workerGroup); + command.setEnvironmentCode(schedule.getEnvironmentCode()); command.setWarningType(schedule.getWarningType()); command.setProcessInstancePriority(schedule.getProcessInstancePriority()); command.setProcessDefinitionVersion(processDefinition.getVersion());
