[dolphinscheduler] branch 2.0.0-release-prepare updated: add is start check..

[leonbao]

This is an automated email from the ASF dual-hosted git repository.

leonbao pushed a commit to branch 2.0.0-release-prepare
in repository https://gitbox.apache.org/repos/asf/dolphinscheduler.git


The following commit(s) were added to refs/heads/2.0.0-release-prepare by this 
push:
     new 604c224  add is start check..
604c224 is described below

commit 604c224346e7405f3e933f5e75d5d46071627367
Author: lenboo <baoliang.l...@gmail.com>
AuthorDate: Wed Nov 17 00:26:26 2021 +0800

    add is start check..
---
 .../dolphinscheduler/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 7c4b321..eae5353 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;
             }