Skip to content

Commit 755977f

Browse files
committed
Fix flaky test SegmentReplicationIT.testDeleteOperations.
Signed-off-by: Marc Handalian <handalm@amazon.com>
1 parent c301544 commit 755977f

1 file changed

Lines changed: 3 additions & 2 deletions

File tree

server/src/internalClusterTest/java/org/opensearch/indices/replication/SegmentReplicationIT.java

Lines changed: 3 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -615,7 +615,7 @@ public void testDeleteOperations() throws Exception {
615615

616616
createIndex(INDEX_NAME);
617617
ensureGreen(INDEX_NAME);
618-
final int initialDocCount = scaledRandomIntBetween(0, 200);
618+
final int initialDocCount = scaledRandomIntBetween(1, 20);
619619
try (
620620
BackgroundIndexer indexer = new BackgroundIndexer(
621621
INDEX_NAME,
@@ -632,7 +632,7 @@ public void testDeleteOperations() throws Exception {
632632
refresh(INDEX_NAME);
633633
waitForSearchableDocs(initialDocCount, nodeA, nodeB);
634634

635-
final int additionalDocCount = scaledRandomIntBetween(0, 200);
635+
final int additionalDocCount = scaledRandomIntBetween(0, 20);
636636
final int expectedHitCount = initialDocCount + additionalDocCount;
637637
indexer.start(additionalDocCount);
638638
waitForDocs(expectedHitCount, indexer);
@@ -641,6 +641,7 @@ public void testDeleteOperations() throws Exception {
641641
ensureGreen(INDEX_NAME);
642642

643643
Set<String> ids = indexer.getIds();
644+
assertFalse(ids.isEmpty());
644645
String id = ids.toArray()[0].toString();
645646
client(nodeA).prepareDelete(INDEX_NAME, id).setRefreshPolicy(WriteRequest.RefreshPolicy.IMMEDIATE).get();
646647

0 commit comments

Comments
 (0)