@@ -318,29 +318,6 @@ public void testJoinValidatorForFIPSLicense() throws Exception {
318318 }
319319 }
320320
321- public void testIndexJoinValidator_Old_And_Rolling () throws Exception {
322- createComponents (Settings .EMPTY );
323- BiConsumer <DiscoveryNode , ClusterState > joinValidator = security .getJoinValidator ();
324- assertNotNull (joinValidator );
325- Version version = VersionUtils .randomVersionBetween (random (), VersionUtils .getFirstVersion (),
326- VersionUtils .getPreviousVersion (Version .V_7_0_0 ));
327- DiscoveryNode node = new DiscoveryNode ("foo" , buildNewFakeTransportAddress (), Version .CURRENT );
328- IndexMetaData indexMetaData = IndexMetaData .builder (SECURITY_MAIN_ALIAS )
329- .settings (settings (version )
330- .put (INDEX_FORMAT_SETTING .getKey (), INTERNAL_MAIN_INDEX_FORMAT - 1 ))
331- .numberOfShards (1 ).numberOfReplicas (0 )
332- .build ();
333- DiscoveryNode existingOtherNode = new DiscoveryNode ("bar" , buildNewFakeTransportAddress (), version );
334- DiscoveryNodes discoveryNodes = DiscoveryNodes .builder ().add (existingOtherNode ).build ();
335- ClusterState clusterState = ClusterState .builder (ClusterName .DEFAULT )
336- .nodes (discoveryNodes )
337- .metaData (MetaData .builder ().put (indexMetaData , true ).build ()).build ();
338- IllegalStateException e = expectThrows (IllegalStateException .class ,
339- () -> joinValidator .accept (node , clusterState ));
340- assertThat (e .getMessage (), equalTo ("Security index is not on the current version [6] - " +
341- "The Upgrade API must be run for 7.x nodes to join the cluster" ));
342- }
343-
344321 public void testIndexJoinValidator_FullyCurrentCluster () throws Exception {
345322 createComponents (Settings .EMPTY );
346323 BiConsumer <DiscoveryNode , ClusterState > joinValidator = security .getJoinValidator ();
0 commit comments