fix

apache · Jan 24, 2025 · d8aa241 · d8aa241
1 parent 2433cdb
commit d8aa241
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/coordinator/src/main/java/org/apache/uniffle/coordinator/SimpleClusterManager.java b/coordinator/src/main/java/org/apache/uniffle/coordinator/SimpleClusterManager.java
@@ -177,7 +177,9 @@ void nodesCheck() {
       // get the active server num.
       Set<String> allServers = new HashSet<>(servers.keySet());
       allServers.removeAll(excludedNodes);
-      allServers.removeAll(unhealthyNodes);
+      for (ServerNode unhealthyNode : unhealthyNodes) {
+        allServers.remove(unhealthyNode.getId());
+      }
       CoordinatorMetrics.gaugeActiveServerNum.set(allServers.size());
 
     } catch (Exception e) {