You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@dolphinscheduler.apache.org by le...@apache.org on 2021/10/16 00:51:18 UTC
[dolphinscheduler] branch 2.0-prepare updated: [Task]fix business
log using error (#6538)
This is an automated email from the ASF dual-hosted git repository.
leonbao pushed a commit to branch 2.0-prepare
in repository https://gitbox.apache.org/repos/asf/dolphinscheduler.git
The following commit(s) were added to refs/heads/2.0-prepare by this push:
new 4723d64 [Task]fix business log using error (#6538)
4723d64 is described below
commit 4723d64d56da290395b0e57f1c92915a2fbf15f5
Author: Kirs <ac...@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;