Fix flaky test SegmentReplicationIT.testDeleteOperations. (#9244)

Signed-off-by: Marc Handalian <[email protected]>
opensearch-project · Aug 11, 2023 · ab08d73 · ab08d73
1 parent 4b21849
commit ab08d73
Showing 1 changed file with 3 additions and 2 deletions.
diff --git a/...src/internalClusterTest/java/org/opensearch/indices/replication/SegmentReplicationIT.java b/...src/internalClusterTest/java/org/opensearch/indices/replication/SegmentReplicationIT.java
@@ -615,7 +615,7 @@ public void testDeleteOperations() throws Exception {
 
         createIndex(INDEX_NAME);
         ensureGreen(INDEX_NAME);
-        final int initialDocCount = scaledRandomIntBetween(0, 200);
+        final int initialDocCount = scaledRandomIntBetween(1, 20);
         try (
             BackgroundIndexer indexer = new BackgroundIndexer(
                 INDEX_NAME,
@@ -632,7 +632,7 @@ public void testDeleteOperations() throws Exception {
             refresh(INDEX_NAME);
             waitForSearchableDocs(initialDocCount, nodeA, nodeB);
 
-            final int additionalDocCount = scaledRandomIntBetween(0, 200);
+            final int additionalDocCount = scaledRandomIntBetween(0, 20);
             final int expectedHitCount = initialDocCount + additionalDocCount;
             indexer.start(additionalDocCount);
             waitForDocs(expectedHitCount, indexer);
@@ -641,6 +641,7 @@ public void testDeleteOperations() throws Exception {
             ensureGreen(INDEX_NAME);
 
             Set<String> ids = indexer.getIds();
+            assertFalse(ids.isEmpty());
             String id = ids.toArray()[0].toString();
             client(nodeA).prepareDelete(INDEX_NAME, id).setRefreshPolicy(WriteRequest.RefreshPolicy.IMMEDIATE).get();