Browse Source

fix can't stop bug (#15191)

Co-authored-by: Leoric Yue <leoric.yue@zoom.us>
Dyqer 1 year ago
parent
commit
cca1c4a172

+ 6 - 3
dolphinscheduler-master/src/main/java/org/apache/dolphinscheduler/server/master/event/WorkflowStateEventHandler.java

@@ -63,10 +63,13 @@ public class WorkflowStateEventHandler implements StateEventHandler {
             }
             workflowExecuteRunnable.endProcess();
         }
-        if (processInstance.getState().isReadyStop()) {
-            workflowExecuteRunnable.killAllTasks();
-        }
 
+        if (workflowStateEvent.getStatus().isReadyStop()) {
+            workflowExecuteRunnable.refreshProcessInstance(processInstance.getId());
+            if (processInstance.getState().isReadyStop()) {
+                workflowExecuteRunnable.killAllTasks();
+            }
+        }
         return true;
     }