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);
}