(dolphinscheduler) branch dev updated: fix can't stop bug (#15191)

[zihaoxiang]

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

zihaoxiang pushed a commit to branch dev
in repository https://gitbox.apache.org/repos/asf/dolphinscheduler.git


The following commit(s) were added to refs/heads/dev by this push:
     new cca1c4a172 fix can't stop bug (#15191)
cca1c4a172 is described below

commit cca1c4a17292e2a71d39be4ce4d828eed75d4a5c
Author: Dyqer <dy...@hotmail.com>
AuthorDate: Mon Nov 20 21:02:44 2023 +0800

    fix can't stop bug (#15191)
    
    Co-authored-by: Leoric Yue <leoric....@zoom.us>
---
 .../server/master/event/WorkflowStateEventHandler.java           | 9 ++++++---
 1 file changed, 6 insertions(+), 3 deletions(-)

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 6db84dadc1..018cff565a 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
@@ -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;
     }