This is an automated email from the ASF dual-hosted git repository.
dataroaring pushed a commit to branch branch-3.0
in repository https://gitbox.apache.org/repos/asf/doris.git
The following commit(s) were added to refs/heads/branch-3.0 by this push:
new 7167b16b872 branch-3.0: [fix](bdbje) avoid remove empty frontends
#46424 (#50472)
7167b16b872 is described below
commit 7167b16b8726a56924e47b368dd197633eee826b
Author: github-actions[bot]
<41898282+github-actions[bot]@users.noreply.github.com>
AuthorDate: Mon Apr 28 19:42:22 2025 +0800
branch-3.0: [fix](bdbje) avoid remove empty frontends #46424 (#50472)
Cherry-picked from #46424
Co-authored-by: Yongqiang YANG <yangyongqi...@selectdb.com>
---
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 a9551f88ff4..f698612d2fd 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
@@ -3172,6 +3172,9 @@ public class Env {
}
private void removeDroppedFrontends(ConcurrentLinkedQueue<String>
removedFrontends) {
+ if (removedFrontends.size() == 0) {
+ return;
+ }
if
(!Strings.isNullOrEmpty(System.getProperty(FeConstants.METADATA_FAILURE_RECOVERY_KEY)))
{
// metadata recovery mode
LOG.info("Metadata failure recovery({}), ignore removing dropped
frontends",
@@ -3181,6 +3184,7 @@ public class Env {
if (haProtocol != null && haProtocol instanceof BDBHA) {
BDBHA bdbha = (BDBHA) haProtocol;
+ LOG.info("remove frontends, num {} frontends {}",
removedFrontends.size(), removedFrontends);
bdbha.removeDroppedMember(removedFrontends);
}
}
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscr...@doris.apache.org
For additional commands, e-mail: commits-h...@doris.apache.org
