[dolphinscheduler] branch dev updated: remove common task log (#9274)

[leonbao]

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

leonbao 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 df519f8  remove common task log (#9274)
df519f8 is described below

commit df519f8044a699911c34675c6e66de14d3f13308
Author: caishunfeng <caishunfeng2...@gmail.com>
AuthorDate: Wed Mar 30 11:42:47 2022 +0800

    remove common task log (#9274)
    
    Co-authored-by: caishunfeng <534328...@qq.com>
---
 .../dolphinscheduler/server/master/runner/FailoverExecuteThread.java    | 2 +-
 .../server/master/runner/WorkflowExecuteThreadPool.java                 | 2 +-
 .../dolphinscheduler/server/master/runner/task/CommonTaskProcessor.java | 2 +-
 3 files changed, 3 insertions(+), 3 deletions(-)

diff --git 
a/dolphinscheduler-master/src/main/java/org/apache/dolphinscheduler/server/master/runner/FailoverExecuteThread.java
 
b/dolphinscheduler-master/src/main/java/org/apache/dolphinscheduler/server/master/runner/FailoverExecuteThread.java
index 144baf2..5dbd6e9 100644
--- 
a/dolphinscheduler-master/src/main/java/org/apache/dolphinscheduler/server/master/runner/FailoverExecuteThread.java
+++ 
b/dolphinscheduler-master/src/main/java/org/apache/dolphinscheduler/server/master/runner/FailoverExecuteThread.java
@@ -64,8 +64,8 @@ public class FailoverExecuteThread extends Thread {
 
     @Override
     public void run() {
+        logger.info("failover execute thread started");
         while (Stopper.isRunning()) {
-            logger.info("failover execute started");
             try {
                 List<String> hosts = getNeedFailoverMasterServers();
                 if (CollectionUtils.isEmpty(hosts)) {
diff --git 
a/dolphinscheduler-master/src/main/java/org/apache/dolphinscheduler/server/master/runner/WorkflowExecuteThreadPool.java
 
b/dolphinscheduler-master/src/main/java/org/apache/dolphinscheduler/server/master/runner/WorkflowExecuteThreadPool.java
index 229d908..8edad98 100644
--- 
a/dolphinscheduler-master/src/main/java/org/apache/dolphinscheduler/server/master/runner/WorkflowExecuteThreadPool.java
+++ 
b/dolphinscheduler-master/src/main/java/org/apache/dolphinscheduler/server/master/runner/WorkflowExecuteThreadPool.java
@@ -84,7 +84,7 @@ public class WorkflowExecuteThreadPool extends 
ThreadPoolTaskExecutor {
     public void submitStateEvent(StateEvent stateEvent) {
         WorkflowExecuteThread workflowExecuteThread = 
processInstanceExecCacheManager.getByProcessInstanceId(stateEvent.getProcessInstanceId());
         if (workflowExecuteThread == null) {
-            logger.error("workflowExecuteThread is null, 
processInstanceId:{}", stateEvent.getProcessInstanceId());
+            logger.warn("workflowExecuteThread is null, stateEvent:{}", 
stateEvent);
             return;
         }
         workflowExecuteThread.addStateEvent(stateEvent);
diff --git 
a/dolphinscheduler-master/src/main/java/org/apache/dolphinscheduler/server/master/runner/task/CommonTaskProcessor.java
 
b/dolphinscheduler-master/src/main/java/org/apache/dolphinscheduler/server/master/runner/task/CommonTaskProcessor.java
index 3d1c518..73e1b16 100644
--- 
a/dolphinscheduler-master/src/main/java/org/apache/dolphinscheduler/server/master/runner/task/CommonTaskProcessor.java
+++ 
b/dolphinscheduler-master/src/main/java/org/apache/dolphinscheduler/server/master/runner/task/CommonTaskProcessor.java
@@ -54,7 +54,7 @@ public class CommonTaskProcessor extends BaseTaskProcessor {
         if (this.taskInstance == null) {
             return false;
         }
-        this.setTaskExecutionLogger();
+
         int taskGroupId = taskInstance.getTaskGroupId();
         if (taskGroupId > 0) {
             boolean acquireTaskGroup = 
processService.acquireTaskGroup(taskInstance.getId(),