You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@doris.apache.org by da...@apache.org on 2025/04/27 09:43:20 UTC
(doris) branch master updated: [fix](bdbje) avoid remove empty frontends (#46424)
This is an automated email from the ASF dual-hosted git repository.
dataroaring pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/doris.git
The following commit(s) were added to refs/heads/master by this push:
new 5c92452c348 [fix](bdbje) avoid remove empty frontends (#46424)
5c92452c348 is described below
commit 5c92452c348cebd52a531da9913bc15899a1e159
Author: Yongqiang YANG <ya...@selectdb.com>
AuthorDate: Sun Apr 27 17:43:12 2025 +0800
[fix](bdbje) avoid remove empty frontends (#46424)
---
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 a3b0c300951..6a0dd429feb 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
@@ -3263,6 +3263,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",
@@ -3272,6 +3275,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-unsubscribe@doris.apache.org
For additional commands, e-mail: commits-help@doris.apache.org