From 875f4fa3bbd610003818bf86322f183f33e4de04 Mon Sep 17 00:00:00 2001 From: Shivansh Arora Date: Thu, 1 Feb 2024 16:37:43 +0530 Subject: [PATCH] Added UsingBatchAction suffix to ITs Signed-off-by: Shivansh Arora --- .../org/opensearch/gateway/RecoveryFromGatewayIT.java | 10 ++++------ 1 file changed, 4 insertions(+), 6 deletions(-) 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);