Browse Source

add is start check..

2.0.7-release
lenboo 3 years ago
parent
commit
604c224346
  1. 1
      dolphinscheduler-server/src/main/java/org/apache/dolphinscheduler/server/master/runner/EventExecuteService.java

1
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()) { for (WorkflowExecuteThread workflowExecuteThread : this.processInstanceExecMaps.values()) {
if (workflowExecuteThread.eventSize() == 0 if (workflowExecuteThread.eventSize() == 0
|| StringUtils.isEmpty(workflowExecuteThread.getKey()) || StringUtils.isEmpty(workflowExecuteThread.getKey())
|| !workflowExecuteThread.isStart()
|| eventHandlerMap.containsKey(workflowExecuteThread.getKey())) { || eventHandlerMap.containsKey(workflowExecuteThread.getKey())) {
continue; continue;
} }

Loading…
Cancel
Save