From de61d65af2fff9f129a3f3c4889328e104f7d2ad Mon Sep 17 00:00:00 2001
From: Kirs <acm_master@163.com>
Date: Fri, 15 Oct 2021 20:27:24 +0800
Subject: [PATCH] [Task]fix business log using error (#6538)

---
 .../server/worker/runner/TaskExecuteThread.java            | 7 +------
 1 file changed, 1 insertion(+), 6 deletions(-)

diff --git a/dolphinscheduler-server/src/main/java/org/apache/dolphinscheduler/server/worker/runner/TaskExecuteThread.java b/dolphinscheduler-server/src/main/java/org/apache/dolphinscheduler/server/worker/runner/TaskExecuteThread.java
index d1f1c39717..a8c823b119 100644
--- a/dolphinscheduler-server/src/main/java/org/apache/dolphinscheduler/server/worker/runner/TaskExecuteThread.java
+++ b/dolphinscheduler-server/src/main/java/org/apache/dolphinscheduler/server/worker/runner/TaskExecuteThread.java
@@ -98,11 +98,6 @@ public class TaskExecuteThread implements Runnable, Delayed {
      */
     private TaskExecutionContextCacheManager taskExecutionContextCacheManager;
 
-    /**
-     * task logger
-     */
-    private Logger taskLogger;
-
     /**
      * alert client server
      */
@@ -143,7 +138,7 @@ public class TaskExecuteThread implements Runnable, Delayed {
             // check if the OS user exists
             if (!OSUtils.getUserList().contains(taskExecutionContext.getTenantCode())) {
                 String errorLog = String.format("tenantCode: %s does not exist", taskExecutionContext.getTenantCode());
-                taskLogger.error(errorLog);
+                logger.error(errorLog);
                 responseCommand.setStatus(ExecutionStatus.FAILURE.getCode());
                 responseCommand.setEndTime(new Date());
                 return;