fix

924060929 · May 29, 2024 · bbd29a6 · bbd29a6
1 parent d35888a
commit bbd29a6
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/fe/fe-core/src/main/java/org/apache/doris/ha/BDBHA.java b/fe/fe-core/src/main/java/org/apache/doris/ha/BDBHA.java
@@ -250,6 +250,9 @@ public synchronized void removeUnReadyElectableNode(String nodeName, int totalFo
 
     public void removeDroppedMember(ConcurrentLinkedQueue<String> removedFrontends) {
         ReplicationGroupAdmin replicationGroupAdmin = environment.getReplicationGroupAdmin();
+        if (replicationGroupAdmin == null) {
+            return;
+        }
         Set<ReplicationNode> replicationNodes = replicationGroupAdmin.getGroup().getElectableNodes();
         LOG.debug("removedFrontends:{}", removedFrontends);
         for (ReplicationNode replicationNode : replicationNodes) {