diff --git a/dolphinscheduler-master/src/main/java/org/apache/dolphinscheduler/server/master/event/WorkflowStateEventHandler.java b/dolphinscheduler-master/src/main/java/org/apache/dolphinscheduler/server/master/event/WorkflowStateEventHandler.java index 685e1bfb6ebb..822b4229ec22 100644 --- a/dolphinscheduler-master/src/main/java/org/apache/dolphinscheduler/server/master/event/WorkflowStateEventHandler.java +++ b/dolphinscheduler-master/src/main/java/org/apache/dolphinscheduler/server/master/event/WorkflowStateEventHandler.java @@ -48,7 +48,6 @@ public boolean handleStateEvent(WorkflowExecuteRunnable workflowExecuteRunnable, if (processDefinition.getExecutionType().typeIsSerialWait() || processDefinition.getExecutionType() .typeIsSerialPriority()) { workflowExecuteRunnable.endProcess(); - return true; } workflowExecuteRunnable.updateProcessInstanceState(workflowStateEvent); return true;