[Fix] After the remove method removes the Server address, the refreshMasterList method needs to be executed. #15964

2024-05-09 17:59:03 +08:00 · 2024-05-09 17:59:03 +08:00 · 6db1c9de36
parent 60b019b729
commit 6db1c9de36
1 changed files with 1 additions and 0 deletions
--- a/dolphinscheduler-service/src/main/java/org/apache/dolphinscheduler/service/queue/MasterPriorityQueue.java
+++ b/dolphinscheduler-service/src/main/java/org/apache/dolphinscheduler/service/queue/MasterPriorityQueue.java
@ -71,6 +71,7 @@ public class MasterPriorityQueue implements TaskPriorityQueue<Server> {

    public void remove(Server server) {
        this.queue.remove(server);
+        refreshMasterList();
    }

    public void clear() {