diff --git a/docs/docs/en/guide/task/sqoop.md b/docs/docs/en/guide/task/sqoop.md
index f62e0ab724..c2523186ea 100644
--- a/docs/docs/en/guide/task/sqoop.md
+++ b/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**                                                                               |
 |-------------------------------------|----------------------------------------------------------------------------------------------------------------------------------------------------------------------------|
 | 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.                                                                                                                                         |
 | Sqoop Advanced Parameters           | Sqoop advanced param for sqoop job.                                                                                                                                        |
 | Data Source - Type                  | Select the corresponding data source type.                                                                                                                                 |
diff --git a/dolphinscheduler-scheduler-plugin/dolphinscheduler-scheduler-quartz/src/main/java/org/apache/dolphinscheduler/scheduler/quartz/ProcessScheduleTask.java b/dolphinscheduler-scheduler-plugin/dolphinscheduler-scheduler-quartz/src/main/java/org/apache/dolphinscheduler/scheduler/quartz/ProcessScheduleTask.java
index 9dfb8ac352..90c4644338 100644
--- a/dolphinscheduler-scheduler-plugin/dolphinscheduler-scheduler-quartz/src/main/java/org/apache/dolphinscheduler/scheduler/quartz/ProcessScheduleTask.java
+++ b/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
                 : schedule.getWorkerGroup();
         command.setWorkerGroup(workerGroup);
+        command.setEnvironmentCode(schedule.getEnvironmentCode());
         command.setWarningType(schedule.getWarningType());
         command.setProcessInstancePriority(schedule.getProcessInstancePriority());
         command.setProcessDefinitionVersion(processDefinition.getVersion());