This is an automated email from the ASF dual-hosted git repository.

tanxinyu pushed a commit to branch rc/1.3.3
in repository https://gitbox.apache.org/repos/asf/iotdb.git


The following commit(s) were added to refs/heads/rc/1.3.3 by this push:
     new 74c72f54993 [to rc/1.3.3] [region migration] Do RatisConsensus 
resetPeerList even if myself not in peer list #13227
74c72f54993 is described below

commit 74c72f549933baf054b213bfb7e7e61eb3c72ddb
Author: Li Yu Heng <[email protected]>
AuthorDate: Mon Aug 19 19:35:51 2024 +0800

    [to rc/1.3.3] [region migration] Do RatisConsensus resetPeerList even if 
myself not in peer list #13227
---
 .../src/main/java/org/apache/iotdb/consensus/ratis/RatisConsensus.java | 3 +--
 1 file changed, 1 insertion(+), 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 1835c69384a..d4bb8d55c8a 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
@@ -562,8 +562,7 @@ class RatisConsensus implements IConsensus {
     final RaftGroupId raftGroupId = 
Utils.fromConsensusGroupIdToRaftGroupId(groupId);
     final RaftGroup group = getGroupInfo(raftGroupId);
 
-    // pre-conditions: group exists and myself in this group
-    if (group == null || !group.getPeers().contains(myself)) {
+    if (group == null) {
       throw new ConsensusGroupNotExistException(groupId);
     }
 

Reply via email to