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 10d6454afe56ab441f390847004b195d14e7db94 Author: Wenjun Ruan <[email protected]> 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());
