increase recovery speed midway

Signed-off-by: Gaurav Bafna <[email protected]>
gbbafna · Jun 12, 2024 · 1c3a788 · 1c3a788
1 parent cd5fcc7
commit 1c3a788
Showing 1 changed file with 6 additions and 0 deletions.
diff --git a/...rc/internalClusterTest/java/org/opensearch/remotemigration/RemotePrimaryRelocationIT.java b/...rc/internalClusterTest/java/org/opensearch/remotemigration/RemotePrimaryRelocationIT.java
@@ -126,6 +126,12 @@ public void testRemotePrimaryRelocation() throws Exception {
         int finalCurrentDoc = currentDoc;
         waitUntil(() -> numAutoGenDocs.get() > finalCurrentDoc + 5);
 
+        // increase recovery speed a bit to account for current size
+        shardSize = client().admin().indices().prepareStats(INDEX_NAME).execute().actionGet().getShards()[0].getStats()
+            .getStore()
+            .size();
+        slowDownRecovery(shardSize);
+
         client().admin()
             .cluster()
             .prepareReroute()