You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by ta...@apache.org on 2022/12/23 08:09:00 UTC
[iotdb] 01/01: remove
This is an automated email from the ASF dual-hosted git repository.
tanxinyu pushed a commit to branch remove_transfer_leader_test
in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit e08d966e1b284d4576c92e821141cb37c93af907
Author: OneSizeFitQuorum <ta...@apache.org>
AuthorDate: Fri Dec 23 16:08:44 2022 +0800
remove
Signed-off-by: OneSizeFitQuorum <ta...@apache.org>
---
.../java/org/apache/iotdb/consensus/ratis/RatisConsensusTest.java | 8 +++++---
1 file changed, 5 insertions(+), 3 deletions(-)
diff --git a/consensus/src/test/java/org/apache/iotdb/consensus/ratis/RatisConsensusTest.java b/consensus/src/test/java/org/apache/iotdb/consensus/ratis/RatisConsensusTest.java
index a519bf29ef..bcb18a34d5 100644
--- a/consensus/src/test/java/org/apache/iotdb/consensus/ratis/RatisConsensusTest.java
+++ b/consensus/src/test/java/org/apache/iotdb/consensus/ratis/RatisConsensusTest.java
@@ -220,7 +220,7 @@ public class RatisConsensusTest {
doConsensus(servers.get(0), gid, 10, 210);
}
- @Test
+ // FIXME: Turn on the test when it is stable
public void transferLeader() throws Exception {
servers.get(0).createPeer(group.getGroupId(), group.getPeers());
servers.get(1).createPeer(group.getGroupId(), group.getPeers());
@@ -234,8 +234,10 @@ public class RatisConsensusTest {
servers.get(0).transferLeader(group.getGroupId(), peers.get((leaderIndex + 1) % 3));
Assert.assertTrue(resp.isSuccess());
- int newLeaderIndex = servers.get(0).getLeader(group.getGroupId()).getNodeId() - 1;
- Assert.assertEquals((leaderIndex + 1) % 3, newLeaderIndex);
+ Peer newLeader = servers.get(0).getLeader(group.getGroupId());
+ Assert.assertNotNull(newLeader);
+
+ Assert.assertEquals((leaderIndex + 1) % 3, newLeader.getNodeId() - 1);
}
@Test