You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@dolphinscheduler.apache.org by zh...@apache.org on 2022/11/28 09:50:31 UTC

[dolphinscheduler] 08/08: [Bug-12954] [Schedule] Fix that workflow-level configuration information does not take effect when timing triggers execution (#12955)

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 <37...@users.noreply.github.com>
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());