Skip to content

Commit

Permalink
more !
Browse files Browse the repository at this point in the history
  • Loading branch information
liyuheng55555 committed Jun 14, 2024
1 parent 7c68a82 commit 496fdaa
Showing 1 changed file with 3 additions and 6 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -42,16 +42,13 @@
@RunWith(IoTDBTestRunner.class)
@Category({ClusterIT.class})
public class IoTDBVerifyConnectionIT {
private static final String testConsensusProtocolClass = ConsensusFactory.RATIS_CONSENSUS;

@Before
public void setUp() throws Exception {
EnvFactory.getEnv()
.getConfig()
.getCommonConfig()
.setConfigNodeConsensusProtocolClass(testConsensusProtocolClass)
.setSchemaRegionConsensusProtocolClass(testConsensusProtocolClass)
.setDataRegionConsensusProtocolClass(testConsensusProtocolClass);
.setConfigNodeConsensusProtocolClass(ConsensusFactory.RATIS_CONSENSUS);
}

@After
Expand All @@ -60,7 +57,7 @@ public void tearDown() throws Exception {
}

@Test
public void verifyConnectionAllUpTest() throws Exception {
public void testVerifyConnectionAllUp() throws Exception {
EnvFactory.getEnv().initClusterEnvironment(3, 3);
try (Connection connection = EnvFactory.getEnv().getConnection();
Statement statement = connection.createStatement()) {
Expand All @@ -74,7 +71,7 @@ public void verifyConnectionAllUpTest() throws Exception {
}

@Test
public void verifyConnectionWithNodeCrashTest() throws Exception {
public void testVerifyConnectionWithNodeCrash() throws Exception {
EnvFactory.getEnv().initClusterEnvironment(3, 1);
try (Connection connection = EnvFactory.getEnv().getConnection();
Statement statement = connection.createStatement()) {
Expand Down

0 comments on commit 496fdaa

Please sign in to comment.