Browse Source

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

3.2.0-release
Kerwin 2 years ago committed by GitHub
parent
commit
2f8f0952fb
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
  1. 2
      docs/docs/en/guide/task/sqoop.md
  2. 1
      dolphinscheduler-scheduler-plugin/dolphinscheduler-scheduler-quartz/src/main/java/org/apache/dolphinscheduler/scheduler/quartz/ProcessScheduleTask.java

2
docs/docs/en/guide/task/sqoop.md

@ -19,7 +19,7 @@ Sqoop task type for executing Sqoop application. The workers run `sqoop` to exec
| **Parameter** | **Description** | | **Parameter** | **Description** |
|-------------------------------------|----------------------------------------------------------------------------------------------------------------------------------------------------------------------------| |-------------------------------------|----------------------------------------------------------------------------------------------------------------------------------------------------------------------------|
| Job Name | map-reduce job name | | Job Name | map-reduce job name |
| Direct | (1) import:Imports an individual table from an RDBMS to HDFS or Hive. (2) export:Exports a set of files from HDFS or Hive back to an RDBMS. | | Direct | (1) import:Imports an individual table from an RDBMS to HDFS or Hive. (2) export:Exports a set of files from HDFS or Hive back to an RDBMS. |
| Hadoop Params | Hadoop custom param for sqoop job. | | Hadoop Params | Hadoop custom param for sqoop job. |
| Sqoop Advanced Parameters | Sqoop advanced param for sqoop job. | | Sqoop Advanced Parameters | Sqoop advanced param for sqoop job. |
| Data Source - Type | Select the corresponding data source type. | | Data Source - Type | Select the corresponding data source type. |

1
dolphinscheduler-scheduler-plugin/dolphinscheduler-scheduler-quartz/src/main/java/org/apache/dolphinscheduler/scheduler/quartz/ProcessScheduleTask.java

@ -100,6 +100,7 @@ public class ProcessScheduleTask extends QuartzJobBean {
String workerGroup = StringUtils.isEmpty(schedule.getWorkerGroup()) ? Constants.DEFAULT_WORKER_GROUP String workerGroup = StringUtils.isEmpty(schedule.getWorkerGroup()) ? Constants.DEFAULT_WORKER_GROUP
: schedule.getWorkerGroup(); : schedule.getWorkerGroup();
command.setWorkerGroup(workerGroup); command.setWorkerGroup(workerGroup);
command.setEnvironmentCode(schedule.getEnvironmentCode());
command.setWarningType(schedule.getWarningType()); command.setWarningType(schedule.getWarningType());
command.setProcessInstancePriority(schedule.getProcessInstancePriority()); command.setProcessInstancePriority(schedule.getProcessInstancePriority());
command.setProcessDefinitionVersion(processDefinition.getVersion()); command.setProcessDefinitionVersion(processDefinition.getVersion());

Loading…
Cancel
Save