remove stale bwc test

Signed-off-by: Nicholas Walter Knize <[email protected]>
opensearch-project · Apr 22, 2022 · 8f49663 · 8f49663
1 parent b1f4ebb
commit 8f49663
Showing 1 changed file with 0 additions and 89 deletions.
diff --git a/server/src/test/java/org/opensearch/cluster/metadata/MetadataIndexStateServiceTests.java b/server/src/test/java/org/opensearch/cluster/metadata/MetadataIndexStateServiceTests.java
@@ -43,9 +43,6 @@
 import org.opensearch.cluster.SnapshotsInProgress;
 import org.opensearch.cluster.block.ClusterBlock;
 import org.opensearch.cluster.block.ClusterBlocks;
-import org.opensearch.cluster.node.DiscoveryNode;
-import org.opensearch.cluster.node.DiscoveryNodeRole;
-import org.opensearch.cluster.node.DiscoveryNodes;
 import org.opensearch.cluster.routing.IndexRoutingTable;
 import org.opensearch.cluster.routing.IndexShardRoutingTable;
 import org.opensearch.cluster.routing.RoutingTable;
@@ -96,7 +93,6 @@
 import static org.hamcrest.Matchers.hasSize;
 import static org.hamcrest.Matchers.is;
 import static org.hamcrest.Matchers.notNullValue;
-import static org.hamcrest.Matchers.nullValue;
 import static org.mockito.Mockito.mock;
 import static org.mockito.Mockito.when;
 
@@ -180,91 +176,6 @@ public void testCloseRoutingTableWithSnapshottedIndex() {
         assertThat(updatedState.blocks().hasIndexBlockWithId(index.getName(), INDEX_CLOSED_BLOCK_ID), is(true));
     }
 
-    public void testCloseRoutingTableRemovesRoutingTable() {
-        final Set<Index> nonBlockedIndices = new HashSet<>();
-        final Map<Index, ClusterBlock> blockedIndices = new HashMap<>();
-        final Map<Index, IndexResult> results = new HashMap<>();
-        final ClusterBlock closingBlock = MetadataIndexStateService.createIndexClosingBlock();
-
-        ClusterState state = ClusterState.builder(new ClusterName("testCloseRoutingTableRemovesRoutingTable")).build();
-        for (int i = 0; i < randomIntBetween(1, 25); i++) {
-            final String indexName = "index-" + i;
-
-            if (randomBoolean()) {
-                state = addOpenedIndex(indexName, randomIntBetween(1, 5), randomIntBetween(0, 5), state);
-                nonBlockedIndices.add(state.metadata().index(indexName).getIndex());
-            } else {
-                state = addBlockedIndex(indexName, randomIntBetween(1, 5), randomIntBetween(0, 5), state, closingBlock);
-                final Index index = state.metadata().index(indexName).getIndex();
-                blockedIndices.put(index, closingBlock);
-                if (randomBoolean()) {
-                    results.put(index, new CloseIndexResponse.IndexResult(index));
-                } else {
-                    results.put(index, new CloseIndexResponse.IndexResult(index, new Exception("test")));
-                }
-            }
-        }
-
-        state = ClusterState.builder(state)
-            .nodes(
-                DiscoveryNodes.builder(state.nodes())
-                    .add(
-                        new DiscoveryNode(
-                            "old_node",
-                            buildNewFakeTransportAddress(),
-                            emptyMap(),
-                            new HashSet<>(DiscoveryNodeRole.BUILT_IN_ROLES),
-                            Version.V_2_0_0
-                        )
-                    )
-                    .add(
-                        new DiscoveryNode(
-                            "new_node",
-                            buildNewFakeTransportAddress(),
-                            emptyMap(),
-                            new HashSet<>(DiscoveryNodeRole.BUILT_IN_ROLES),
-                            Version.V_2_1_0
-                        )
-                    )
-            )
-            .build();
-
-        state = MetadataIndexStateService.closeRoutingTable(state, blockedIndices, results).v1();
-        assertThat(state.metadata().indices().size(), equalTo(nonBlockedIndices.size() + blockedIndices.size()));
-
-        for (Index nonBlockedIndex : nonBlockedIndices) {
-            assertIsOpened(nonBlockedIndex.getName(), state);
-            assertThat(state.blocks().hasIndexBlockWithId(nonBlockedIndex.getName(), INDEX_CLOSED_BLOCK_ID), is(false));
-        }
-        for (Index blockedIndex : blockedIndices.keySet()) {
-            if (results.get(blockedIndex).hasFailures() == false) {
-                IndexMetadata indexMetadata = state.metadata().index(blockedIndex);
-                assertThat(indexMetadata.getState(), is(IndexMetadata.State.CLOSE));
-                Settings indexSettings = indexMetadata.getSettings();
-                assertThat(indexSettings.hasValue(MetadataIndexStateService.VERIFIED_BEFORE_CLOSE_SETTING.getKey()), is(false));
-                assertThat(state.blocks().hasIndexBlock(blockedIndex.getName(), MetadataIndexStateService.INDEX_CLOSED_BLOCK), is(true));
-                assertThat(
-                    "Index must have only 1 block with [id=" + MetadataIndexStateService.INDEX_CLOSED_BLOCK_ID + "]",
-                    state.blocks()
-                        .indices()
-                        .getOrDefault(blockedIndex.getName(), emptySet())
-                        .stream()
-                        .filter(clusterBlock -> clusterBlock.id() == MetadataIndexStateService.INDEX_CLOSED_BLOCK_ID)
-                        .count(),
-                    equalTo(1L)
-                );
-                assertThat(
-                    "Index routing table should have been removed when closing the index on mixed cluster version",
-                    state.routingTable().index(blockedIndex),
-                    nullValue()
-                );
-            } else {
-                assertIsOpened(blockedIndex.getName(), state);
-                assertThat(state.blocks().hasIndexBlock(blockedIndex.getName(), closingBlock), is(true));
-            }
-        }
-    }
-
     public void testAddIndexClosedBlocks() {
         final ClusterState initialState = ClusterState.builder(new ClusterName("testAddIndexClosedBlocks")).build();
         {