diff --git a/fe/fe-core/src/main/java/org/apache/doris/common/proc/FrontendsProcNode.java b/fe/fe-core/src/main/java/org/apache/doris/common/proc/FrontendsProcNode.java index b49874b6e9..be126e9bc5 100644 --- a/fe/fe-core/src/main/java/org/apache/doris/common/proc/FrontendsProcNode.java +++ b/fe/fe-core/src/main/java/org/apache/doris/common/proc/FrontendsProcNode.java @@ -127,7 +127,6 @@ public class FrontendsProcNode implements ProcNodeInterface { } for (Frontend fe : env.getFrontends(null /* all */)) { - List info = new ArrayList(); info.add(fe.getNodeName()); info.add(fe.getHost()); 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 index 40de732922..046bca5bac 100644 --- 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 @@ -104,11 +104,12 @@ public class BDBHA implements HAProtocol { @Override public List getObserverNodes() { + List ret = new ArrayList(); ReplicationGroupAdmin replicationGroupAdmin = environment.getReplicationGroupAdmin(); if (replicationGroupAdmin == null) { - return null; + return ret; } - List ret = new ArrayList(); + try { ReplicationGroup replicationGroup = replicationGroupAdmin.getGroup(); for (ReplicationNode replicationNode : replicationGroup.getSecondaryNodes()) { @@ -123,11 +124,12 @@ public class BDBHA implements HAProtocol { @Override public List getElectableNodes(boolean leaderIncluded) { + List ret = new ArrayList(); ReplicationGroupAdmin replicationGroupAdmin = environment.getReplicationGroupAdmin(); if (replicationGroupAdmin == null) { - return null; + return ret; } - List ret = new ArrayList(); + try { ReplicationGroup replicationGroup = replicationGroupAdmin.getGroup(); for (ReplicationNode replicationNode : replicationGroup.getElectableNodes()) { diff --git a/fe/fe-core/src/main/java/org/apache/doris/journal/bdbje/BDBEnvironment.java b/fe/fe-core/src/main/java/org/apache/doris/journal/bdbje/BDBEnvironment.java index 5dec4a4c57..1b608751c7 100644 --- a/fe/fe-core/src/main/java/org/apache/doris/journal/bdbje/BDBEnvironment.java +++ b/fe/fe-core/src/main/java/org/apache/doris/journal/bdbje/BDBEnvironment.java @@ -209,6 +209,11 @@ public class BDBEnvironment { .filter(Frontend::isAlive) .map(fe -> new InetSocketAddress(fe.getHost(), fe.getEditLogPort())) .collect(Collectors.toSet()); + + if (addresses.isEmpty()) { + LOG.info("addresses is empty"); + return null; + } return new ReplicationGroupAdmin(PALO_JOURNAL_GROUP, addresses); }