You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@dolphinscheduler.apache.org by le...@apache.org on 2021/11/16 16:29:52 UTC
[dolphinscheduler] branch 2.0.0-release updated: add is start check..
This is an automated email from the ASF dual-hosted git repository.
leonbao pushed a commit to branch 2.0.0-release
in repository https://gitbox.apache.org/repos/asf/dolphinscheduler.git
The following commit(s) were added to refs/heads/2.0.0-release by this push:
new c5fdcaa add is start check..
c5fdcaa is described below
commit c5fdcaa12c24ae48d11b149539a97585bde6b100
Author: lenboo <ba...@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;
}