Address PR comments

Signed-off-by: Gaurav Bafna <[email protected]>
gbbafna · Oct 8, 2024 · c8ed1da · c8ed1da
1 parent 5c89fc0
commit c8ed1da
Showing 1 changed file with 3 additions and 11 deletions.
diff --git a/...rc/internalClusterTest/java/org/opensearch/remotemigration/RemotePrimaryRelocationIT.java b/...rc/internalClusterTest/java/org/opensearch/remotemigration/RemotePrimaryRelocationIT.java
@@ -63,19 +63,11 @@ public void testRemotePrimaryRelocation() throws Exception {
         assertAcked(client().admin().cluster().updateSettings(updateSettingsRequest).actionGet());
 
         // create shard with 1 replica and 1 shard
-        client().admin().indices().prepareCreate(INDEX_NAME).setSettings(indexSettings()).setMapping("field", "type=text").get();
+        Settings settings = super.indexSettings();
+        settings = Settings.builder().put(settings).put(IndexMetadata.SETTING_NUMBER_OF_REPLICAS, 1).build();
+        client().admin().indices().prepareCreate(INDEX_NAME).setSettings(settings).setMapping("field", "type=text").get();
         ensureGreen(INDEX_NAME);
 
-        assertAcked(
-            internalCluster().client()
-                .admin()
-                .indices()
-                .prepareUpdateSettings()
-                .setIndices(INDEX_NAME)
-                .setSettings(Settings.builder().put(IndexMetadata.SETTING_NUMBER_OF_REPLICAS, 1).build())
-                .get()
-        );
-
         AtomicInteger numAutoGenDocs = new AtomicInteger();
         final AtomicBoolean finished = new AtomicBoolean(false);
         AsyncIndexingService asyncIndexingService = new AsyncIndexingService(INDEX_NAME);