Browse Source

[Task]fix business log using error (#6538)

3.0.0/version-upgrade
Kirs 3 years ago committed by GitHub
parent
commit
de61d65af2
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
  1. 7
      dolphinscheduler-server/src/main/java/org/apache/dolphinscheduler/server/worker/runner/TaskExecuteThread.java

7
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; private TaskExecutionContextCacheManager taskExecutionContextCacheManager;
/**
* task logger
*/
private Logger taskLogger;
/** /**
* alert client server * alert client server
*/ */
@ -143,7 +138,7 @@ public class TaskExecuteThread implements Runnable, Delayed {
// check if the OS user exists // check if the OS user exists
if (!OSUtils.getUserList().contains(taskExecutionContext.getTenantCode())) { if (!OSUtils.getUserList().contains(taskExecutionContext.getTenantCode())) {
String errorLog = String.format("tenantCode: %s does not exist", 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.setStatus(ExecutionStatus.FAILURE.getCode());
responseCommand.setEndTime(new Date()); responseCommand.setEndTime(new Date());
return; return;

Loading…
Cancel
Save