[dolphinscheduler] branch dev updated: [Task]fix business log using error (#6538)

[jinyleechina]

This is an automated email from the ASF dual-hosted git repository.

jinyleechina pushed a commit to branch dev
in repository https://gitbox.apache.org/repos/asf/dolphinscheduler.git


The following commit(s) were added to refs/heads/dev by this push:
     new de61d65  [Task]fix business log using error (#6538)
de61d65 is described below

commit de61d65af2fff9f129a3f3c4889328e104f7d2ad
Author: Kirs <acm_mas...@163.com>
AuthorDate: Fri Oct 15 20:27:24 2021 +0800

    [Task]fix business log using error (#6538)
---
 .../dolphinscheduler/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 d1f1c39..a8c823b 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
@@ -99,11 +99,6 @@ public class TaskExecuteThread implements Runnable, Delayed {
     private TaskExecutionContextCacheManager taskExecutionContextCacheManager;
 
     /**
-     * task logger
-     */
-    private Logger taskLogger;
-
-    /**
      * alert client server
      */
     private AlertClientService alertClientService;
@@ -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;