From 628c8ab2a144a4d49d60f02a08e7cdc1672970de Mon Sep 17 00:00:00 2001
From: pinkhello <lee123lee123@163.com>
Date: Sun, 26 Jun 2022 10:07:35 +0800
Subject: [PATCH] [Improvement][Master] batch remove TaskInstaceId and
 workflowInstanceId (#10620)

---
 .../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();
         }
     }
 }