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