[dolphinscheduler] branch dev updated: [Improvement][Master] batch remove TaskInstaceId and workflowInstanceId (#10620)

[wenjun]

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

wenjun 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 628c8ab2a1 [Improvement][Master] batch remove TaskInstaceId and 
workflowInstanceId (#10620)
628c8ab2a1 is described below

commit 628c8ab2a144a4d49d60f02a08e7cdc1672970de
Author: pinkhello <lee123lee...@163.com>
AuthorDate: Sun Jun 26 10:07:35 2022 +0800

    [Improvement][Master] batch remove TaskInstaceId and workflowInstanceId 
(#10620)
---
 .../dolphinscheduler/server/master/processor/TaskRecallProcessor.java   | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git 
a/dolphinscheduler-master/src/main/java/org/apache/dolphinscheduler/server/master/processor/TaskRecallProcessor.java
 
b/dolphinscheduler-master/src/main/java/org/apache/dolphinscheduler/server/master/processor/TaskRecallProcessor.java
index 91614c48c9..e37dc6e06a 100644
--- 
a/dolphinscheduler-master/src/main/java/org/apache/dolphinscheduler/server/master/processor/TaskRecallProcessor.java
+++ 
b/dolphinscheduler-master/src/main/java/org/apache/dolphinscheduler/server/master/processor/TaskRecallProcessor.java
@@ -62,7 +62,7 @@ public class TaskRecallProcessor implements 
NettyRequestProcessor {
             logger.info("Receive task recall command: {}", recallCommand);
             taskEventService.addEvent(taskEvent);
         } finally {
-            LoggerUtils.removeWorkflowInstanceIdMDC();
+            LoggerUtils.removeWorkflowAndTaskInstanceIdMDC();
         }
     }
 }