From db35121b40c3aaa99f9a721a6a32eaaee7e3bba2 Mon Sep 17 00:00:00 2001 From: Yongqiang YANG Date: Sun, 5 Jan 2025 10:09:21 +0800 Subject: [PATCH] [fix](bdbje) avoid remove empty frontends --- fe/fe-core/src/main/java/org/apache/doris/catalog/Env.java | 4 ++++ 1 file changed, 4 insertions(+) diff --git a/fe/fe-core/src/main/java/org/apache/doris/catalog/Env.java b/fe/fe-core/src/main/java/org/apache/doris/catalog/Env.java index 19865446456967..dab0483e530785 100644 --- a/fe/fe-core/src/main/java/org/apache/doris/catalog/Env.java +++ b/fe/fe-core/src/main/java/org/apache/doris/catalog/Env.java @@ -3179,8 +3179,12 @@ public void dropFrontendFromBDBJE(FrontendNodeType role, String host, int port) } private void removeDroppedFrontends(ConcurrentLinkedQueue removedFrontends) { + if (removedFrontends.size() == 0) { + return; + } if (haProtocol != null && haProtocol instanceof BDBHA) { BDBHA bdbha = (BDBHA) haProtocol; + LOG.info("remove frontends, num {} frontends {}", removedFrontends.size(), removedFrontends); bdbha.removeDroppedMember(removedFrontends); } }