diff --git a/server/src/internalClusterTest/java/org/opensearch/gateway/RecoveryFromGatewayIT.java b/server/src/internalClusterTest/java/org/opensearch/gateway/RecoveryFromGatewayIT.java index 34c069f74c62a..b222b14b862e8 100644 --- a/server/src/internalClusterTest/java/org/opensearch/gateway/RecoveryFromGatewayIT.java +++ b/server/src/internalClusterTest/java/org/opensearch/gateway/RecoveryFromGatewayIT.java @@ -749,7 +749,7 @@ public void testMessyElectionsStillMakeClusterGoGreen() throws Exception { ensureGreen("test"); } - public void testSingleShardStoreFetch() throws ExecutionException, InterruptedException { + public void testSingleShardStoreFetchUsingBatchAction() throws ExecutionException, InterruptedException { String indexName = "test"; DiscoveryNode[] nodes = getDiscoveryNodes(); TransportNodesListShardStoreMetadataBatch.NodesStoreFilesMetadataBatch response = prepareAndSendRequest( @@ -765,8 +765,7 @@ public void testSingleShardStoreFetch() throws ExecutionException, InterruptedEx assertNodeStoreFilesMetadataSuccessCase(nodeStoreFilesMetadata, shardId); } - public void testShardStoreFetchMultiNodeMultiIndexes() throws Exception { - // start second node + public void testShardStoreFetchMultiNodeMultiIndexesUsingBatchAction() throws Exception { internalCluster().startNode(); String indexName1 = "test1"; String indexName2 = "test2"; @@ -790,7 +789,7 @@ public void testShardStoreFetchMultiNodeMultiIndexes() throws Exception { } } - public void testShardStoreFetchNodeNotConnected() { + public void testShardStoreFetchNodeNotConnectedUsingBatchAction() { DiscoveryNode nonExistingNode = new DiscoveryNode("foo", buildNewFakeTransportAddress(), emptyMap(), emptySet(), Version.CURRENT); String indexName = "test"; TransportNodesListShardStoreMetadataBatch.NodesStoreFilesMetadataBatch response = prepareAndSendRequest( @@ -802,8 +801,7 @@ public void testShardStoreFetchNodeNotConnected() { assertEquals(nonExistingNode.getId(), response.failures().get(0).nodeId()); } - public void testShardStoreFetchCorruptedIndex() throws Exception { - // start second node + public void testShardStoreFetchCorruptedIndexUsingBatchAction() throws Exception { internalCluster().startNode(); String indexName = "test"; prepareIndices(new String[] { indexName }, 1, 1);