From d8aa241a51874c3a82cefcda40825dc0fc58ddbd Mon Sep 17 00:00:00 2001
From: Junfan Zhang <zhangjunfan@qiyi.com>
Date: Fri, 24 Jan 2025 17:38:10 +0800
Subject: [PATCH] fix

---
 .../org/apache/uniffle/coordinator/SimpleClusterManager.java  | 4 +++-
 1 file changed, 3 insertions(+), 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
index ed842a31bb..5d9e88db37 100644
--- 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) {