Skip to content

Commit a7805b1

Browse files
SWJTU-ZhangLeidataroaring
authored andcommitted
[fix](fe) Fix removeDroppedMember use incorrect nodeName (#37987)
``` com.sleepycat.je.rep.MasterStateException: (JE 18.3.12) Cannot remove an active master at com.sleepycat.je.rep.util.ReplicationGroupAdmin.checkMember(ReplicationGroupAdmin.java:591) at com.sleepycat.je.rep.util.ReplicationGroupAdmin.removeMember(ReplicationGroupAdmin.java:315) at org.apache.doris.ha.BDBHA.removeDroppedMember(BDBHA.java:262) at org.apache.doris.catalog.Env.removeDroppedFrontends(Env.java:3077) at org.apache.doris.catalog.Env.transferToMaster(Env.java:1520) at org.apache.doris.catalog.Env.access$1300(Env.java:338) at org.apache.doris.catalog.Env$5.runOneCycle(Env.java:2792) at org.apache.doris.common.util.Daemon.run(Daemon.java:116) ``` * the bug is introduced by #35203
1 parent 19e0650 commit a7805b1

File tree

1 file changed

+3
-3
lines changed
  • fe/fe-core/src/main/java/org/apache/doris/ha

1 file changed

+3
-3
lines changed

fe/fe-core/src/main/java/org/apache/doris/ha/BDBHA.java

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -259,11 +259,11 @@ public void removeDroppedMember(ConcurrentLinkedQueue<String> removedFrontends)
259259
LOG.debug("node:{}", replicationNode.toString());
260260
if (removedFrontends.contains(replicationNode.getName())) {
261261
try {
262-
replicationGroupAdmin.removeMember(nodeName);
262+
replicationGroupAdmin.removeMember(replicationNode.getName());
263263
} catch (MemberNotFoundException e) {
264-
LOG.warn("the electable node is not found {}", nodeName);
264+
LOG.warn("the electable node is not found {}", replicationNode.getName());
265265
} catch (Exception e) {
266-
LOG.error("remove electable node {} meeting unknown exception:", nodeName, e);
266+
LOG.error("remove electable node {} meeting unknown exception:", replicationNode.getName(), e);
267267
System.exit(-1);
268268
}
269269
}

0 commit comments

Comments
 (0)