Skip to content

Commit

Permalink
Added UsingBatchAction suffix to ITs
Browse files Browse the repository at this point in the history
Signed-off-by: Shivansh Arora <[email protected]>
  • Loading branch information
shiv0408 committed Feb 1, 2024
1 parent 5bc6202 commit 875f4fa
Showing 1 changed file with 4 additions and 6 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -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(
Expand All @@ -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";
Expand All @@ -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(
Expand All @@ -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);
Expand Down

0 comments on commit 875f4fa

Please sign in to comment.