Skip to content

Commit 1d1a501

Browse files
committed
trigger junit test.
1 parent d740e51 commit 1d1a501

File tree

2 files changed

+6
-0
lines changed

2 files changed

+6
-0
lines changed

ratis-server/src/test/java/org/apache/ratis/InstallSnapshotNotificationTests.java

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -178,6 +178,7 @@ public void testAddNewFollowers() throws Exception {
178178

179179
@Test
180180
public void testAddNewFollowersNoSnapshot() throws Exception {
181+
LOG.info("trigger testAddNewFollowersNoSnapshot.");
181182
final int numRequests = SNAPSHOT_TRIGGER_THRESHOLD/8; // do not trigger a snapshot;
182183
runWithNewCluster(1, c -> testAddNewFollowers(c, numRequests));
183184
}

ratis-server/src/test/java/org/apache/ratis/RaftAsyncTests.java

Lines changed: 5 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -119,6 +119,7 @@ public void testRequestAsyncWithRetryFailure() throws Exception {
119119

120120
@Test
121121
public void testRequestAsyncWithRetryFailureAfterInitialMessages() throws Exception {
122+
LOG.info("trigger testRequestAsyncWithRetryFailureAfterInitialMessages.");
122123
runTestRequestAsyncWithRetryFailure(true);
123124
}
124125

@@ -201,6 +202,7 @@ void runTestRequestAsyncWithRetryFailure(boolean initialMessages, CLUSTER cluste
201202

202203
@Test
203204
public void testAsyncRequestSemaphore() throws Exception {
205+
LOG.info("trigger testAsyncRequestSemaphore.");
204206
runWithNewCluster(NUM_SERVERS, this::runTestAsyncRequestSemaphore);
205207
}
206208

@@ -271,6 +273,7 @@ public void testBasicAppendEntriesAsyncKillLeader() throws Exception {
271273

272274
@Test
273275
public void testWithLoadAsync() throws Exception {
276+
LOG.info("trigger testWithLoadAsync.");
274277
runWithNewCluster(NUM_SERVERS,
275278
cluster -> RaftBasicTests.testWithLoad(5, 500, true, cluster, LOG));
276279
}
@@ -392,6 +395,7 @@ void runTestWriteAsyncCustomReplicationLevel(CLUSTER cluster) throws Exception {
392395

393396
@Test
394397
public void testRequestTimeout() throws Exception {
398+
LOG.info("trigger testRequestTimeout");
395399
final TimeDuration oldExpiryTime = RaftServerConfigKeys.RetryCache.expiryTime(getProperties());
396400
RaftServerConfigKeys.RetryCache.setExpiryTime(getProperties(), FIVE_SECONDS);
397401
RaftClientConfigKeys.Async.Experimental.setSendDummyRequest(getProperties(), false);
@@ -493,6 +497,7 @@ void runTestCheckLeadershipFailure(CLUSTER cluster) throws Exception {
493497

494498
@Test
495499
public void testNoRetryWaitOnNotLeaderException() throws Exception {
500+
LOG.info("trigger testNoRetryWaitOnNotLeaderException.");
496501
RaftClientConfigKeys.Async.Experimental.setSendDummyRequest(getProperties(), false);
497502
runWithNewCluster(3, this::runTestNoRetryWaitOnNotLeaderException);
498503
RaftClientConfigKeys.Async.Experimental.setSendDummyRequest(getProperties(), true);

0 commit comments

Comments
 (0)