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