add more tasks

Mrhs121 · Mrhs121 · commit 80f2b46c6af8 · 2026-04-13T14:19:01.000+08:00
diff --git a/dolphinscheduler-api/src/main/java/org/apache/dolphinscheduler/api/executor/logging/TaskLogType.java b/dolphinscheduler-api/src/main/java/org/apache/dolphinscheduler/api/executor/logging/TaskLogType.java
@@ -32,7 +32,7 @@ public String getLogPath(TaskInstance taskInstance) {
 
         @Override
         public String getLogPath(TaskInstance taskInstance) {
-            return taskInstance.getTaskOutPutLogPath();
+            return taskInstance.getTaskOutputLogPath();
         }
     };
 
diff --git a/dolphinscheduler-api/src/test/java/org/apache/dolphinscheduler/api/service/LoggerServiceTest.java b/dolphinscheduler-api/src/test/java/org/apache/dolphinscheduler/api/service/LoggerServiceTest.java
@@ -187,7 +187,7 @@ public void testQueryTaskOutputAndGetOutputBytes() {
         taskInstance.setId(1);
         taskInstance.setExecutorId(loginUser.getId() + 1);
         taskInstance.setHost("127.0.0.1:" + nettyServerPort);
-        taskInstance.setTaskOutPutLogPath("/temp/output.log");
+        taskInstance.setTaskOutputLogPath("/temp/output.log");
         when(taskInstanceDao.queryById(1)).thenReturn(taskInstance);
 
         doNothing().when(projectService).checkProjectAndAuthThrowException(loginUser, taskInstance.getProjectCode(),
diff --git a/dolphinscheduler-dao/src/main/java/org/apache/dolphinscheduler/dao/entity/TaskInstance.java b/dolphinscheduler-dao/src/main/java/org/apache/dolphinscheduler/dao/entity/TaskInstance.java
@@ -80,7 +80,8 @@ public class TaskInstance implements Serializable {
     private String executePath;
 
     private String logPath;
-    private String taskOutPutLogPath;
+    @TableField("task_output_log_path")
+    private String taskOutputLogPath;
 
     private int retryTimes;
 
diff --git a/dolphinscheduler-dao/src/main/resources/org/apache/dolphinscheduler/dao/mapper/TaskInstanceMapper.xml b/dolphinscheduler-dao/src/main/resources/org/apache/dolphinscheduler/dao/mapper/TaskInstanceMapper.xml
@@ -20,13 +20,13 @@
 <mapper namespace="org.apache.dolphinscheduler.dao.mapper.TaskInstanceMapper">
     <sql id="baseSql">
         id, name, task_type, workflow_instance_id, workflow_instance_name, project_code, task_code, task_definition_version, state, submit_time,
-        start_time, end_time, host, execute_path, log_path, alert_flag, retry_times, pid, app_link,
+        start_time, end_time, host, execute_path, log_path, task_output_log_path, alert_flag, retry_times, pid, app_link,
         flag, retry_interval, max_retry_times, task_instance_priority, worker_group,environment_code , executor_id, executor_name,
         first_submit_time, delay_time, task_params, var_pool, dry_run, task_group_id, cpu_quota, memory_max, task_execute_type
     </sql>
     <sql id="baseSqlV2">
         ${alias}.id, ${alias}.name, ${alias}.task_type, ${alias}.task_code, ${alias}.task_definition_version, ${alias}.workflow_instance_id, ${alias}.state, ${alias}.submit_time,
-        ${alias}.start_time, ${alias}.end_time, ${alias}.host, ${alias}.execute_path, ${alias}.log_path, ${alias}.alert_flag, ${alias}.retry_times, ${alias}.pid, ${alias}.app_link,
+        ${alias}.start_time, ${alias}.end_time, ${alias}.host, ${alias}.execute_path, ${alias}.log_path, ${alias}.task_output_log_path, ${alias}.alert_flag, ${alias}.retry_times, ${alias}.pid, ${alias}.app_link,
         ${alias}.flag, ${alias}.retry_interval, ${alias}.max_retry_times, ${alias}.task_instance_priority, ${alias}.worker_group,${alias}.environment_code , ${alias}.executor_id,
         ${alias}.first_submit_time, ${alias}.delay_time, ${alias}.task_params, ${alias}.var_pool, ${alias}.dry_run, ${alias}.task_group_id, ${alias}.task_execute_type
     </sql>
diff --git a/dolphinscheduler-dao/src/main/resources/sql/dolphinscheduler_h2.sql b/dolphinscheduler-dao/src/main/resources/sql/dolphinscheduler_h2.sql
@@ -915,6 +915,7 @@ CREATE TABLE t_ds_task_instance
     host                    varchar(135) DEFAULT NULL,
     execute_path            varchar(200) DEFAULT NULL,
     log_path                longtext DEFAULT NULL,
+    task_output_log_path    longtext DEFAULT NULL,
     alert_flag              tinyint(4) DEFAULT NULL,
     retry_times             int(4) DEFAULT '0',
     pid                     int(4) DEFAULT NULL,
diff --git a/dolphinscheduler-dao/src/main/resources/sql/dolphinscheduler_mysql.sql b/dolphinscheduler-dao/src/main/resources/sql/dolphinscheduler_mysql.sql
@@ -914,6 +914,7 @@ CREATE TABLE `t_ds_task_instance` (
   `host` varchar(135) DEFAULT NULL COMMENT 'host of task running on',
   `execute_path` varchar(200) DEFAULT NULL COMMENT 'task execute path in the host',
   `log_path` longtext DEFAULT NULL COMMENT 'task log path',
+  `task_output_log_path` longtext DEFAULT NULL COMMENT 'task output log path',
   `alert_flag` tinyint(4) DEFAULT NULL COMMENT 'whether alert',
   `retry_times` int(4) DEFAULT '0' COMMENT 'task retry times',
   `pid` int(4) DEFAULT NULL COMMENT 'pid of task',
diff --git a/dolphinscheduler-dao/src/main/resources/sql/dolphinscheduler_postgresql.sql b/dolphinscheduler-dao/src/main/resources/sql/dolphinscheduler_postgresql.sql
@@ -834,6 +834,7 @@ CREATE TABLE t_ds_task_instance (
   host varchar(135) DEFAULT NULL ,
   execute_path varchar(200) DEFAULT NULL ,
   log_path text DEFAULT NULL ,
+  task_output_log_path text DEFAULT NULL ,
   alert_flag int DEFAULT NULL ,
   retry_times int DEFAULT '0' ,
   pid int DEFAULT NULL ,
diff --git a/dolphinscheduler-dao/src/main/resources/sql/upgrade/3.4.1_schema/mysql/dolphinscheduler_ddl.sql b/dolphinscheduler-dao/src/main/resources/sql/upgrade/3.4.1_schema/mysql/dolphinscheduler_ddl.sql
@@ -16,4 +16,22 @@
 */
 
 ALTER TABLE `t_ds_serial_command`
-MODIFY COLUMN `workflow_definition_code` BIGINT(20) NOT NULL COMMENT 'workflow definition code';
+MODIFY COLUMN `workflow_definition_code` BIGINT(20) NOT NULL COMMENT 'workflow definition code';
+
+drop PROCEDURE if EXISTS add_task_output_log_path_to_t_ds_task_instance;
+delimiter d//
+CREATE PROCEDURE add_task_output_log_path_to_t_ds_task_instance()
+BEGIN
+    IF NOT EXISTS (SELECT 1 FROM INFORMATION_SCHEMA.COLUMNS
+        WHERE TABLE_NAME='t_ds_task_instance'
+          AND TABLE_SCHEMA=(SELECT DATABASE())
+          AND COLUMN_NAME='task_output_log_path')
+    THEN
+        ALTER TABLE `t_ds_task_instance`
+            ADD COLUMN `task_output_log_path` longtext DEFAULT NULL COMMENT 'task output log path' AFTER `log_path`;
+    END IF;
+END;
+d//
+delimiter ;
+call add_task_output_log_path_to_t_ds_task_instance();
+drop PROCEDURE if EXISTS add_task_output_log_path_to_t_ds_task_instance;
diff --git a/dolphinscheduler-dao/src/main/resources/sql/upgrade/3.4.1_schema/postgresql/dolphinscheduler_ddl.sql b/dolphinscheduler-dao/src/main/resources/sql/upgrade/3.4.1_schema/postgresql/dolphinscheduler_ddl.sql
@@ -18,3 +18,6 @@
 CREATE SEQUENCE IF NOT EXISTS t_ds_task_instance_context_id_seq;
 ALTER TABLE t_ds_task_instance_context
 ALTER COLUMN id SET DEFAULT nextval('t_ds_task_instance_context_id_seq'::regclass);
+
+ALTER TABLE t_ds_task_instance
+ADD COLUMN IF NOT EXISTS task_output_log_path text DEFAULT NULL;
diff --git a/dolphinscheduler-master/src/main/java/org/apache/dolphinscheduler/server/master/engine/task/execution/AbstractTaskInstanceFactory.java b/dolphinscheduler-master/src/main/java/org/apache/dolphinscheduler/server/master/engine/task/execution/AbstractTaskInstanceFactory.java
@@ -50,7 +50,7 @@ protected TaskInstance cloneTaskInstance(TaskInstance originTaskInstance) {
         result.setEndTime(originTaskInstance.getEndTime());
         result.setHost(originTaskInstance.getHost());
         result.setExecutePath(originTaskInstance.getExecutePath());
-        result.setTaskOutPutLogPath(originTaskInstance.getTaskOutPutLogPath());
+        result.setTaskOutputLogPath(originTaskInstance.getTaskOutputLogPath());
         result.setLogPath(originTaskInstance.getLogPath());
         result.setRetryTimes(originTaskInstance.getRetryTimes());
         result.setAlertFlag(originTaskInstance.getAlertFlag());
diff --git a/dolphinscheduler-master/src/main/java/org/apache/dolphinscheduler/server/master/engine/task/lifecycle/event/TaskRunningLifecycleEvent.java b/dolphinscheduler-master/src/main/java/org/apache/dolphinscheduler/server/master/engine/task/lifecycle/event/TaskRunningLifecycleEvent.java
@@ -36,7 +36,7 @@ public class TaskRunningLifecycleEvent extends AbstractTaskLifecycleEvent {
     private final ITaskExecution taskExecution;
 
     private final String logPath;
-    private final String taskOutPutLogPath;
+    private final String taskOutputLogPath;
 
     private final Date startTime;
 
@@ -50,7 +50,7 @@ public String toString() {
         return "TaskRunningLifecycleEvent{" +
                 "task=" + taskExecution.getName() +
                 ", logPath='" + logPath + '\'' +
-                ", taskOutPutLogPath='" + taskOutPutLogPath + '\'' +
+                ", taskOutputLogPath='" + taskOutputLogPath + '\'' +
                 ", startTime=" + startTime +
                 '}';
     }
diff --git a/dolphinscheduler-master/src/main/java/org/apache/dolphinscheduler/server/master/engine/task/statemachine/AbstractTaskStateAction.java b/dolphinscheduler-master/src/main/java/org/apache/dolphinscheduler/server/master/engine/task/statemachine/AbstractTaskStateAction.java
@@ -160,7 +160,7 @@ protected void persistentTaskInstanceStartedEventToDB(final ITaskExecution taskE
         taskInstance.setState(TaskExecutionStatus.RUNNING_EXECUTION);
         taskInstance.setStartTime(taskRunningEvent.getStartTime());
         taskInstance.setLogPath(taskRunningEvent.getLogPath());
-        taskInstance.setTaskOutPutLogPath(taskRunningEvent.getTaskOutPutLogPath());
+        taskInstance.setTaskOutputLogPath(taskRunningEvent.getTaskOutputLogPath());
         taskInstanceDao.updateById(taskInstance);
     }
 
diff --git a/dolphinscheduler-master/src/main/java/org/apache/dolphinscheduler/server/master/rpc/TaskExecutorEventListenerImpl.java b/dolphinscheduler-master/src/main/java/org/apache/dolphinscheduler/server/master/rpc/TaskExecutorEventListenerImpl.java
@@ -79,7 +79,7 @@ public void onTaskExecutorRunning(final TaskExecutorStartedLifecycleEvent taskEx
                     .taskExecution(taskExecution)
                     .startTime(new Date(taskExecutorStartedLifecycleEvent.getStartTime()))
                     .logPath(taskExecutorStartedLifecycleEvent.getLogPath())
-                    .taskOutPutLogPath(taskExecutorStartedLifecycleEvent.getTaskOutputLogPath())
+                    .taskOutputLogPath(taskExecutorStartedLifecycleEvent.getTaskOutputLogPath())
                     .build();
 
             taskExecution.getWorkflowEventBus().publish(taskRunningEvent);
diff --git a/dolphinscheduler-task-plugin/dolphinscheduler-task-api/src/main/java/org/apache/dolphinscheduler/plugin/task/api/AbstractCommandExecutor.java b/dolphinscheduler-task-plugin/dolphinscheduler-task-api/src/main/java/org/apache/dolphinscheduler/plugin/task/api/AbstractCommandExecutor.java
@@ -199,7 +199,10 @@ private Optional<CompletableFuture<?>> collectPodLogIfNeeded() {
         final CompletableFuture<Void> collectPodLogFuture = CompletableFuture.runAsync(() -> {
             // wait for launching (driver) pod
             ThreadUtils.sleep(SLEEP_TIME_MILLIS * 5L);
+            LogUtils.setTaskInstanceLogFullPathMDC(taskRequest.getLogPath());
             try (
+                    LogUtils.MDCAutoClosableContext ignored =
+                            LogUtils.withTaskOutputLogPathMDC(taskRequest.getTaskOutputLogPath());
                     LogWatch watcher = ProcessUtils.getPodLogWatcher(taskRequest.getK8sTaskExecutionContext(),
                             taskRequest.getTaskAppId(), "")) {
                 if (watcher == null) {
@@ -208,13 +211,19 @@ private Optional<CompletableFuture<?>> collectPodLogIfNeeded() {
                     String line;
                     try (BufferedReader reader = new BufferedReader(new InputStreamReader(watcher.getOutput()))) {
                         while ((line = reader.readLine()) != null) {
-                            log.info("[K8S-pod-log-{}]: {}", taskRequest.getTaskName(), line);
+                            if (StringUtils.isBlank(taskRequest.getTaskOutputLogPath())) {
+                                log.info("[K8S-pod-log-{}]: {}", taskRequest.getTaskName(), line);
+                            } else {
+                                TASK_OUTPUT_LOGGER.info(line);
+                            }
                         }
                     }
                 }
             } catch (Exception e) {
                 log.error("Collect pod log error", e);
                 throw new RuntimeException(e);
+            } finally {
+                LogUtils.removeTaskInstanceLogFullPathMDC();
             }
         }, collectPodLogExecutorService);
 
diff --git a/dolphinscheduler-task-plugin/dolphinscheduler-task-http/src/main/java/org/apache/dolphinscheduler/plugin/task/http/HttpTask.java b/dolphinscheduler-task-plugin/dolphinscheduler-task-http/src/main/java/org/apache/dolphinscheduler/plugin/task/http/HttpTask.java
@@ -31,6 +31,7 @@
 import org.apache.dolphinscheduler.plugin.task.api.enums.Direct;
 import org.apache.dolphinscheduler.plugin.task.api.model.Property;
 import org.apache.dolphinscheduler.plugin.task.api.parameters.AbstractParameters;
+import org.apache.dolphinscheduler.plugin.task.api.utils.LogUtils;
 import org.apache.dolphinscheduler.plugin.task.api.utils.ParameterUtils;
 
 import org.apache.commons.lang3.StringUtils;
@@ -41,12 +42,17 @@
 import lombok.SneakyThrows;
 import lombok.extern.slf4j.Slf4j;
 
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
 import com.fasterxml.jackson.core.type.TypeReference;
 import com.fasterxml.jackson.databind.JsonNode;
 
 @Slf4j
 public class HttpTask extends AbstractTask {
 
+    private static final Logger TASK_OUTPUT_LOGGER = LoggerFactory.getLogger(LogUtils.TASK_OUTPUT_LOGGER_NAME);
+
     private HttpParameters httpParameters;
 
     private TaskExecutionContext taskExecutionContext;
@@ -89,32 +95,32 @@ private void validateResponse(String body, int statusCode) {
         switch (httpParameters.getHttpCheckCondition()) {
             case BODY_CONTAINS:
                 if (StringUtils.isEmpty(body) || !body.contains(httpParameters.getCondition())) {
-                    log.error("http request failed, url: {}, statusCode: {}, checkCondition: {}, body: {}",
-                            httpParameters.getUrl(), statusCode, HttpCheckCondition.BODY_CONTAINS.name(), body);
+                    logHttpResponse("http request failed, url: {}, statusCode: {}, checkCondition: {}, body: {}",
+                            statusCode, HttpCheckCondition.BODY_CONTAINS.name(), body);
                     exitStatusCode = TaskConstants.EXIT_CODE_FAILURE;
                     return;
                 }
                 break;
             case BODY_NOT_CONTAINS:
                 if (StringUtils.isEmpty(body) || body.contains(httpParameters.getCondition())) {
-                    log.error("http request failed, url: {}, statusCode: {}, checkCondition: {}, body: {}",
-                            httpParameters.getUrl(), statusCode, HttpCheckCondition.BODY_NOT_CONTAINS.name(), body);
+                    logHttpResponse("http request failed, url: {}, statusCode: {}, checkCondition: {}, body: {}",
+                            statusCode, HttpCheckCondition.BODY_NOT_CONTAINS.name(), body);
                     exitStatusCode = TaskConstants.EXIT_CODE_FAILURE;
                     return;
                 }
                 break;
             case STATUS_CODE_CUSTOM:
                 if (statusCode != Integer.parseInt(httpParameters.getCondition())) {
-                    log.error("http request failed, url: {}, statusCode: {}, checkCondition: {}, body: {}",
-                            httpParameters.getUrl(), statusCode, HttpCheckCondition.STATUS_CODE_CUSTOM.name(), body);
+                    logHttpResponse("http request failed, url: {}, statusCode: {}, checkCondition: {}, body: {}",
+                            statusCode, HttpCheckCondition.STATUS_CODE_CUSTOM.name(), body);
                     exitStatusCode = TaskConstants.EXIT_CODE_FAILURE;
                     return;
                 }
                 break;
             case STATUS_CODE_DEFAULT:
                 if (HttpConstants.RESPONSE_CODE_SUCCESS != statusCode) {
-                    log.error("http request failed, url: {}, statusCode: {}, checkCondition: {}, body: {}",
-                            httpParameters.getUrl(), statusCode, HttpCheckCondition.STATUS_CODE_DEFAULT.name(), body);
+                    logHttpResponse("http request failed, url: {}, statusCode: {}, checkCondition: {}, body: {}",
+                            statusCode, HttpCheckCondition.STATUS_CODE_DEFAULT.name(), body);
                     exitStatusCode = TaskConstants.EXIT_CODE_FAILURE;
                     return;
                 }
@@ -125,10 +131,33 @@ private void validateResponse(String body, int statusCode) {
         }
 
         // default success log
-        log.info("http request success, url: {}, statusCode: {}, body: {}", httpParameters.getUrl(), statusCode, body);
+        logHttpResponse("http request success, url: {}, statusCode: {}, body: {}", statusCode, null, body);
         exitStatusCode = TaskConstants.EXIT_CODE_SUCCESS;
     }
 
+    private void logHttpResponse(String message, int statusCode, String checkCondition, String body) {
+        if (StringUtils.isBlank(taskExecutionContext.getTaskOutputLogPath())) {
+            if (checkCondition == null) {
+                log.info(message, httpParameters.getUrl(), statusCode, body);
+            } else {
+                log.error(message, httpParameters.getUrl(), statusCode, checkCondition, body);
+            }
+            return;
+        }
+        LogUtils.setTaskInstanceLogFullPathMDC(taskExecutionContext.getLogPath());
+        try (
+                LogUtils.MDCAutoClosableContext ignored =
+                        LogUtils.withTaskOutputLogPathMDC(taskExecutionContext.getTaskOutputLogPath())) {
+            if (checkCondition == null) {
+                TASK_OUTPUT_LOGGER.info(message, httpParameters.getUrl(), statusCode, body);
+            } else {
+                TASK_OUTPUT_LOGGER.info(message, httpParameters.getUrl(), statusCode, checkCondition, body);
+            }
+        } finally {
+            LogUtils.removeTaskInstanceLogFullPathMDC();
+        }
+    }
+
     private OkHttpResponse sendRequest() {
         switch (httpParameters.getHttpRequestMethod()) {
             case GET:
diff --git a/dolphinscheduler-task-plugin/dolphinscheduler-task-procedure/src/main/java/org/apache/dolphinscheduler/plugin/task/procedure/ProcedureTask.java b/dolphinscheduler-task-plugin/dolphinscheduler-task-procedure/src/main/java/org/apache/dolphinscheduler/plugin/task/procedure/ProcedureTask.java
@@ -34,6 +34,7 @@
 import org.apache.dolphinscheduler.plugin.task.api.enums.TaskTimeoutStrategy;
 import org.apache.dolphinscheduler.plugin.task.api.model.Property;
 import org.apache.dolphinscheduler.plugin.task.api.parameters.AbstractParameters;
+import org.apache.dolphinscheduler.plugin.task.api.utils.LogUtils;
 import org.apache.dolphinscheduler.plugin.task.api.utils.ParameterUtils;
 import org.apache.dolphinscheduler.spi.datasource.ConnectionParam;
 import org.apache.dolphinscheduler.spi.enums.DbType;
@@ -51,9 +52,14 @@
 
 import lombok.extern.slf4j.Slf4j;
 
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
 @Slf4j
 public class ProcedureTask extends AbstractTask {
 
+    private static final Logger TASK_OUTPUT_LOGGER = LoggerFactory.getLogger(LogUtils.TASK_OUTPUT_LOGGER_NAME);
+
     private final ProcedureParameters procedureParameters;
 
     private final TaskExecutionContext taskExecutionContext;
@@ -234,47 +240,55 @@ private Object getOutputParameter(CallableStatement stmt, int index, String prop
         Object value = null;
         switch (dataType) {
             case VARCHAR:
-                log.info("out parameter varchar key : {} , value : {}", prop, stmt.getString(index));
                 value = stmt.getString(index);
                 break;
             case INTEGER:
-                log.info("out parameter integer key : {} , value : {}", prop, stmt.getInt(index));
                 value = stmt.getInt(index);
                 break;
             case LONG:
-                log.info("out parameter long key : {} , value : {}", prop, stmt.getLong(index));
                 value = stmt.getLong(index);
                 break;
             case FLOAT:
-                log.info("out parameter float key : {} , value : {}", prop, stmt.getFloat(index));
                 value = stmt.getFloat(index);
                 break;
             case DOUBLE:
-                log.info("out parameter double key : {} , value : {}", prop, stmt.getDouble(index));
                 value = stmt.getDouble(index);
                 break;
             case DATE:
-                log.info("out parameter date key : {} , value : {}", prop, stmt.getDate(index));
                 value = stmt.getDate(index);
                 break;
             case TIME:
-                log.info("out parameter time key : {} , value : {}", prop, stmt.getTime(index));
                 value = stmt.getTime(index);
                 break;
             case TIMESTAMP:
-                log.info("out parameter timestamp key : {} , value : {}", prop, stmt.getTimestamp(index));
                 value = stmt.getTimestamp(index);
                 break;
             case BOOLEAN:
-                log.info("out parameter boolean key : {} , value : {}", prop, stmt.getBoolean(index));
                 value = stmt.getBoolean(index);
                 break;
             default:
                 break;
         }
+        logOutputParameter(prop, dataType, value);
         return value;
     }
 
+    private void logOutputParameter(String prop, DataType dataType, Object value) {
+        String message = String.format("out parameter %s key : {} , value : {}", dataType.name().toLowerCase());
+        if (StringUtils.isBlank(taskExecutionContext.getTaskOutputLogPath())) {
+            log.info(message, prop, value);
+            return;
+        }
+        LogUtils.setTaskInstanceLogFullPathMDC(taskExecutionContext.getLogPath());
+        try (
+                LogUtils.MDCAutoClosableContext ignored =
+                        LogUtils.withTaskOutputLogPathMDC(taskExecutionContext.getTaskOutputLogPath())) {
+            TASK_OUTPUT_LOGGER.info(message, prop, value);
+        } finally {
+            LogUtils.removeTaskInstanceLogFullPathMDC();
+        }
+    }
+
     @Override
     public AbstractParameters getParameters() {
         return procedureParameters;
diff --git a/dolphinscheduler-task-plugin/dolphinscheduler-task-remoteshell/src/main/java/org/apache/dolphinscheduler/plugin/task/remoteshell/RemoteExecutor.java b/dolphinscheduler-task-plugin/dolphinscheduler-task-remoteshell/src/main/java/org/apache/dolphinscheduler/plugin/task/remoteshell/RemoteExecutor.java
diff --git a/dolphinscheduler-task-plugin/dolphinscheduler-task-remoteshell/src/main/java/org/apache/dolphinscheduler/plugin/task/remoteshell/RemoteShellTask.java b/dolphinscheduler-task-plugin/dolphinscheduler-task-remoteshell/src/main/java/org/apache/dolphinscheduler/plugin/task/remoteshell/RemoteShellTask.java

Original file line number	Diff line number	Diff line change
`@@ -32,7 +32,7 @@ public String getLogPath(TaskInstance taskInstance) {`
`32`	`32`
`33`	`33`	`@Override`
`34`	`34`	`public String getLogPath(TaskInstance taskInstance) {`
`35`		`- return taskInstance.getTaskOutPutLogPath();`
	`35`	`+ return taskInstance.getTaskOutputLogPath();`
`36`	`36`	`}`
`37`	`37`	`};`
`38`	`38`