[Segment Replication] testReplicationOnDone Add timeout to allow time…

… for verify call Signed-off-by: Suraj Singh <surajrider@gmail.com>
opensearch-project · Aug 29, 2022 · cbb0624 · cbb0624
1 parent 7ea6e88
commit cbb0624
Showing 1 changed file with 1 addition and 2 deletions.
diff --git a/...rc/test/java/org/opensearch/indices/replication/SegmentReplicationTargetServiceTests.java b/...rc/test/java/org/opensearch/indices/replication/SegmentReplicationTargetServiceTests.java
@@ -252,9 +252,8 @@ public void testReplicationOnDone() throws IOException {
         SegmentReplicationTargetService.SegmentReplicationListener listener = captor.getValue();
         listener.onDone(new SegmentReplicationState(new ReplicationLuceneIndex()));
         doNothing().when(spy).onNewCheckpoint(any(), any());
-        verify(spy, timeout(0).times(2)).onNewCheckpoint(eq(anotherNewCheckpoint), any());
+        verify(spy, timeout(100).times(2)).onNewCheckpoint(eq(anotherNewCheckpoint), any());
         closeShard(indexShard, false);
-
     }
 
     public void testBeforeIndexShardClosed_CancelsOngoingReplications() {