Skip to content

Commit

Permalink
[fix](bdbje) avoid remove empty frontends
Browse files Browse the repository at this point in the history
  • Loading branch information
Yongqiang YANG committed Jan 5, 2025
1 parent 8f87a96 commit db35121
Showing 1 changed file with 4 additions and 0 deletions.
4 changes: 4 additions & 0 deletions fe/fe-core/src/main/java/org/apache/doris/catalog/Env.java
Original file line number Diff line number Diff line change
Expand Up @@ -3179,8 +3179,12 @@ public void dropFrontendFromBDBJE(FrontendNodeType role, String host, int port)
}

private void removeDroppedFrontends(ConcurrentLinkedQueue<String> 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);
}
}
Expand Down

0 comments on commit db35121

Please sign in to comment.