Fix tests

Signed-off-by: Shivansh Arora <[email protected]>
Gaurav614 · Feb 12, 2024 · 6843eb2 · 6843eb2
1 parent 350f9f4
commit 6843eb2
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/server/src/internalClusterTest/java/org/opensearch/gateway/RecoveryFromGatewayIT.java b/server/src/internalClusterTest/java/org/opensearch/gateway/RecoveryFromGatewayIT.java
@@ -850,7 +850,7 @@ public void testSingleShardStoreFetchUsingBatchAction() throws ExecutionExceptio
     }
 
     public void testShardStoreFetchMultiNodeMultiIndexesUsingBatchAction() throws Exception {
-        internalCluster().startNode();
+        internalCluster().startNodes(2);
         String indexName1 = "test1";
         String indexName2 = "test2";
         DiscoveryNode[] nodes = getDiscoveryNodes();
@@ -886,7 +886,7 @@ public void testShardStoreFetchNodeNotConnectedUsingBatchAction() {
     }
 
     public void testShardStoreFetchCorruptedIndexUsingBatchAction() throws Exception {
-        internalCluster().startNode();
+        internalCluster().startNodes(2);
         String indexName = "test";
         prepareIndices(new String[] { indexName }, 1, 1);
         Map<ShardId, ShardAttributes> shardAttributesMap = prepareRequestMap(new String[] { indexName }, 1);