Disable scheduled refresh

Signed-off-by: Marc Handalian <[email protected]>
opensearch-project · Jan 30, 2024 · d5002a2 · d5002a2
1 parent a12eee1
commit d5002a2
Showing 1 changed file with 8 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
@@ -989,7 +989,13 @@ private void assertAllocationIdsInReplicaShardStats(Set<String> expected, Set<Se
     public void testScrollCreatedOnReplica() throws Exception {
         // create the cluster with one primary node containing primary shard and replica node containing replica shard
         final String primary = internalCluster().startDataOnlyNode();
-        createIndex(INDEX_NAME);
+        prepareCreate(
+            INDEX_NAME,
+            Settings.builder()
+                .put(indexSettings())
+                // we want to control refreshes
+                .put("index.refresh_interval", -1)
+        ).get();
         ensureYellowAndNoInitializingShards(INDEX_NAME);
         final String replica = internalCluster().startDataOnlyNode();
         ensureGreen(INDEX_NAME);
@@ -1032,9 +1038,9 @@ public void testScrollCreatedOnReplica() throws Exception {
                 .setId(String.valueOf(i))
                 .setSource(jsonBuilder().startObject().field("field", i).endObject())
                 .get();
+            refresh(INDEX_NAME);
         }
         // create new on-disk segments and copy them out.
-        refresh(INDEX_NAME);
         assertBusy(() -> {
             assertEquals(
                 getIndexShard(primary, INDEX_NAME).getLatestReplicationCheckpoint().getSegmentInfosVersion(),