You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@dolphinscheduler.apache.org by we...@apache.org on 2022/11/01 01:30:30 UTC
[dolphinscheduler] 05/05: Refresh coronation when delete workflow instance
This is an automated email from the ASF dual-hosted git repository.
wenjun pushed a commit to branch dev_wenjun_coronationTask
in repository https://gitbox.apache.org/repos/asf/dolphinscheduler.git
commit 040a9eb71865d216202a38d35102e8e98357fe6b
Author: Wenjun Ruan <we...@apache.org>
AuthorDate: Tue Nov 1 09:29:10 2022 +0800
Refresh coronation when delete workflow instance
---
.../server/master/service/IsolationMetadataManager.java | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
diff --git a/dolphinscheduler-master/src/main/java/org/apache/dolphinscheduler/server/master/service/IsolationMetadataManager.java b/dolphinscheduler-master/src/main/java/org/apache/dolphinscheduler/server/master/service/IsolationMetadataManager.java
index d90a95a42d..25b3014cc7 100644
--- a/dolphinscheduler-master/src/main/java/org/apache/dolphinscheduler/server/master/service/IsolationMetadataManager.java
+++ b/dolphinscheduler-master/src/main/java/org/apache/dolphinscheduler/server/master/service/IsolationMetadataManager.java
@@ -47,12 +47,12 @@ public class IsolationMetadataManager {
.stream()
.collect(Collectors.toMap(IsolationTask::getId, Function.identity()));
- List<IsolationTask> needToAddIsolationTasks = isolationTasksInMemory.values()
+ List<IsolationTask> needToCancelIsolationTasks = isolationTasksInMemory.values()
.stream()
.filter(isolationTask -> !isolationTasksInDB.containsKey(isolationTask.getId()))
.collect(Collectors.toList());
- List<IsolationTask> needToCancelIsolationTasks = isolationTasksInDB.values()
+ List<IsolationTask> needToAddIsolationTasks = isolationTasksInDB.values()
.stream()
.filter(isolationTask -> !isolationTasksInMemory.containsKey(isolationTask.getId()))
.collect(Collectors.toList());