You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@dolphinscheduler.apache.org by zi...@apache.org on 2023/11/20 13:02:52 UTC
(dolphinscheduler) branch dev updated: fix can't stop bug (#15191)
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 <le...@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;
}