diff --git a/sandbox/plugins/composite-engine/src/internalClusterTest/java/org/opensearch/composite/DataFormatAwareReplicaGetByIdIT.java b/sandbox/plugins/composite-engine/src/internalClusterTest/java/org/opensearch/composite/DataFormatAwareReplicaGetByIdIT.java index 273492121ee5d..695369c48d964 100644 --- a/sandbox/plugins/composite-engine/src/internalClusterTest/java/org/opensearch/composite/DataFormatAwareReplicaGetByIdIT.java +++ b/sandbox/plugins/composite-engine/src/internalClusterTest/java/org/opensearch/composite/DataFormatAwareReplicaGetByIdIT.java @@ -26,9 +26,11 @@ public class DataFormatAwareReplicaGetByIdIT extends DataFormatAwareReplicationBaseIT { public void testGetByIdFromReplica() throws Exception { - int maxDocs = randomInt(20); + // At least one doc: assertCatalogSnapshotsConverged asserts the lucene index/ has segment + // data files beyond segments_N, which an empty index never produces (randomInt(20) can be 0). + int maxDocs = randomIntBetween(1, 20); createDfaIndex(1); // 1 replica, 2 data nodes (from base) - List ids = indexDocs(maxDocs); // ids 0..19, RefreshPolicy.NONE + List ids = indexDocs(maxDocs); // ids 1..20, RefreshPolicy.NONE client().admin().indices().prepareRefresh(INDEX_NAME).get(); // Ensure the replica's catalog has converged with the primary (segments replicated). assertCatalogSnapshotsConverged(INDEX_NAME);