From ba778c6a8642aed8d616472e2d0f4b53bd76c78e Mon Sep 17 00:00:00 2001 From: "Jinrui.Zhang" Date: Wed, 16 Aug 2023 14:49:52 +0800 Subject: [PATCH] fix ratis remove peer not detected correctly by ConfigNode --- .../org/apache/iotdb/consensus/ratis/RatisConsensus.java | 5 +++-- 1 file changed, 3 insertions(+), 2 deletions(-) diff --git a/iotdb-core/consensus/src/main/java/org/apache/iotdb/consensus/ratis/RatisConsensus.java b/iotdb-core/consensus/src/main/java/org/apache/iotdb/consensus/ratis/RatisConsensus.java index 27c8bb0d27..600eead4ca 100644 --- a/iotdb-core/consensus/src/main/java/org/apache/iotdb/consensus/ratis/RatisConsensus.java +++ b/iotdb-core/consensus/src/main/java/org/apache/iotdb/consensus/ratis/RatisConsensus.java @@ -48,7 +48,6 @@ import org.apache.iotdb.consensus.exception.ConsensusException; import org.apache.iotdb.consensus.exception.ConsensusGroupNotExistException; import org.apache.iotdb.consensus.exception.NodeReadOnlyException; import org.apache.iotdb.consensus.exception.PeerAlreadyInConsensusGroupException; -import org.apache.iotdb.consensus.exception.PeerNotInConsensusGroupException; import org.apache.iotdb.consensus.exception.RatisRequestFailedException; import org.apache.iotdb.consensus.exception.RatisUnderRecoveryException; import org.apache.iotdb.consensus.ratis.metrics.RatisMetricSet; @@ -497,7 +496,9 @@ class RatisConsensus implements IConsensus { } // pre-condition: peer is a member of groupId if (!group.getPeers().contains(peerToRemove)) { - return failed(new PeerNotInConsensusGroupException(groupId, myself)); + logger.error("duplicated peer remove operation detected. {}-{}", groupId, peer); + return ConsensusGenericResponse.newBuilder().setSuccess(true).build(); + // return failed(new PeerNotInConsensusGroupException(groupId, myself)); } // update group peer information -- GitLab