From 216a6ae0d4f7958ec1ac6a46da0ffb65f22bea3d Mon Sep 17 00:00:00 2001 From: OneSizeFitQuorum Date: Wed, 24 Apr 2024 11:21:50 +0800 Subject: [PATCH 1/2] fix Signed-off-by: OneSizeFitQuorum --- .../main/java/org/apache/ratis/server/impl/LeaderElection.java | 2 ++ 1 file changed, 2 insertions(+) diff --git a/ratis-server/src/main/java/org/apache/ratis/server/impl/LeaderElection.java b/ratis-server/src/main/java/org/apache/ratis/server/impl/LeaderElection.java index 53e83d866e..e91da15655 100644 --- a/ratis-server/src/main/java/org/apache/ratis/server/impl/LeaderElection.java +++ b/ratis-server/src/main/java/org/apache/ratis/server/impl/LeaderElection.java @@ -332,6 +332,8 @@ private boolean askForVotes(Phase phase, int round) throws InterruptedException, case SINGLE_MODE_PASSED: return true; case NOT_IN_CONF: + server.close(); + return false; case SHUTDOWN: server.getRaftServer().close(); server.getStateMachine().event().notifyServerShutdown(server.getRoleInfoProto()); From 3b01b28553833a5ac53fbb2a713f07c86c76fb92 Mon Sep 17 00:00:00 2001 From: OneSizeFitQuorum Date: Thu, 25 Apr 2024 13:27:48 +0800 Subject: [PATCH 2/2] fix review Signed-off-by: OneSizeFitQuorum --- .../java/org/apache/ratis/server/impl/LeaderElection.java | 4 +--- 1 file changed, 1 insertion(+), 3 deletions(-) diff --git a/ratis-server/src/main/java/org/apache/ratis/server/impl/LeaderElection.java b/ratis-server/src/main/java/org/apache/ratis/server/impl/LeaderElection.java index e91da15655..d738c87578 100644 --- a/ratis-server/src/main/java/org/apache/ratis/server/impl/LeaderElection.java +++ b/ratis-server/src/main/java/org/apache/ratis/server/impl/LeaderElection.java @@ -332,10 +332,8 @@ private boolean askForVotes(Phase phase, int round) throws InterruptedException, case SINGLE_MODE_PASSED: return true; case NOT_IN_CONF: - server.close(); - return false; case SHUTDOWN: - server.getRaftServer().close(); + server.close(); server.getStateMachine().event().notifyServerShutdown(server.getRoleInfoProto()); return false; case TIMEOUT: