Ver código fonte

[Improvement][Master] batch remove TaskInstaceId and workflowInstanceId (#10620)

pinkhello 2 anos atrás
pai
commit
628c8ab2a1

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