We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent cd5fcc7 commit 1c3a788Copy full SHA for 1c3a788
server/src/internalClusterTest/java/org/opensearch/remotemigration/RemotePrimaryRelocationIT.java
@@ -126,6 +126,12 @@ public void testRemotePrimaryRelocation() throws Exception {
126
int finalCurrentDoc = currentDoc;
127
waitUntil(() -> numAutoGenDocs.get() > finalCurrentDoc + 5);
128
129
+ // increase recovery speed a bit to account for current size
130
+ shardSize = client().admin().indices().prepareStats(INDEX_NAME).execute().actionGet().getShards()[0].getStats()
131
+ .getStore()
132
+ .size();
133
+ slowDownRecovery(shardSize);
134
+
135
client().admin()
136
.cluster()
137
.prepareReroute()
0 commit comments