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 <[email protected]>
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: [email protected]
For additional commands, e-mail: [email protected]
