This is an automated email from the ASF dual-hosted git repository.
leonbao 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 5741c75 [DS-6771][MasterServer] fix failover worker interrupt (#6801)
5741c75 is described below
commit 5741c758b3521885e4ea11fdcb3c66d275537739
Author: wind <[email protected]>
AuthorDate: Fri Nov 12 14:19:57 2021 +0800
[DS-6771][MasterServer] fix failover worker interrupt (#6801)
Co-authored-by: caishunfeng <[email protected]>
Co-authored-by: Kirs <[email protected]>
Co-authored-by: OS <[email protected]>
---
.../dolphinscheduler/server/master/registry/MasterRegistryClient.java | 3 ++-
1 file changed, 2 insertions(+), 1 deletion(-)
diff --git
a/dolphinscheduler-server/src/main/java/org/apache/dolphinscheduler/server/master/registry/MasterRegistryClient.java
b/dolphinscheduler-server/src/main/java/org/apache/dolphinscheduler/server/master/registry/MasterRegistryClient.java
index 6c47f84..edd5406 100644
---
a/dolphinscheduler-server/src/main/java/org/apache/dolphinscheduler/server/master/registry/MasterRegistryClient.java
+++
b/dolphinscheduler-server/src/main/java/org/apache/dolphinscheduler/server/master/registry/MasterRegistryClient.java
@@ -309,8 +309,9 @@ public class MasterRegistryClient {
taskInstance.setState(ExecutionStatus.NEED_FAULT_TOLERANCE);
processService.saveTaskInstance(taskInstance);
+
if
(!processInstanceExecCacheManager.contains(processInstance.getId())) {
- return;
+ continue;
}
WorkflowExecuteThread workflowExecuteThreadNotify =
processInstanceExecCacheManager.getByProcessInstanceId(processInstance.getId());
StateEvent stateEvent = new StateEvent();
