add is start check..

2021-11-17 00:26:26 +08:00 · 2021-11-17 00:26:26 +08:00 · c5fdcaa12c
parent 446a4c5e38
commit c5fdcaa12c
1 changed files with 1 additions and 0 deletions
--- 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;
            }