From 604c224346e7405f3e933f5e75d5d46071627367 Mon Sep 17 00:00:00 2001 From: lenboo Date: Wed, 17 Nov 2021 00:26:26 +0800 Subject: [PATCH] add is start check.. --- .../server/master/runner/EventExecuteService.java | 1 + 1 file changed, 1 insertion(+) diff --git a/dolphinscheduler-server/src/main/java/org/apache/dolphinscheduler/server/master/runner/EventExecuteService.java b/dolphinscheduler-server/src/main/java/org/apache/dolphinscheduler/server/master/runner/EventExecuteService.java index 7c4b32130d..eae5353175 100644 --- a/dolphinscheduler-server/src/main/java/org/apache/dolphinscheduler/server/master/runner/EventExecuteService.java +++ b/dolphinscheduler-server/src/main/java/org/apache/dolphinscheduler/server/master/runner/EventExecuteService.java @@ -118,6 +118,7 @@ public class EventExecuteService extends Thread { for (WorkflowExecuteThread workflowExecuteThread : this.processInstanceExecMaps.values()) { if (workflowExecuteThread.eventSize() == 0 || StringUtils.isEmpty(workflowExecuteThread.getKey()) + || !workflowExecuteThread.isStart() || eventHandlerMap.containsKey(workflowExecuteThread.getKey())) { continue; }