5252import org .apache .ignite .internal .GridKernalContext ;
5353import org .apache .ignite .internal .IgniteComponentType ;
5454import org .apache .ignite .internal .IgniteInternalFuture ;
55- import org .apache .ignite .internal .managers .discovery .DiscoCache ;
5655import org .apache .ignite .internal .processors .cache .DynamicCacheDescriptor ;
5756import org .apache .ignite .internal .processors .cluster .BaselineTopology ;
5857import org .apache .ignite .internal .processors .cluster .baseline .autoadjust .BaselineAutoAdjustStatus ;
6867import org .apache .ignite .internal .util .typedef .F ;
6968import org .apache .ignite .internal .util .typedef .internal .A ;
7069import org .apache .ignite .internal .util .typedef .internal .CU ;
71- import org .apache .ignite .internal .util .typedef .internal .SB ;
7270import org .apache .ignite .internal .util .typedef .internal .U ;
7371import org .apache .ignite .lang .IgniteBiTuple ;
7472import org .apache .ignite .lang .IgniteFuture ;
7573import org .apache .ignite .lang .IgnitePredicate ;
76- import org .apache .ignite .lang .IgniteProductVersion ;
7774import org .jetbrains .annotations .Nullable ;
7875
7976import static org .apache .ignite .cluster .ClusterState .ACTIVE ;
@@ -100,9 +97,6 @@ public class IgniteClusterImpl extends ClusterGroupAdapter implements IgniteClus
10097 /** Client reconnect future. */
10198 private IgniteFuture <?> reconnecFut ;
10299
103- /** Minimal IgniteProductVersion supporting BaselineTopology */
104- private static final IgniteProductVersion MIN_BLT_SUPPORTING_VER = IgniteProductVersion .fromString ("2.4.0" );
105-
106100 /** Unique ID of cluster. Generated on start, shared by all nodes. */
107101 private volatile UUID id ;
108102
@@ -459,38 +453,10 @@ public void triggerBaselineAutoAdjust(long topVer) {
459453 setBaselineTopology (topVer , true );
460454 }
461455
462- /**
463- * Verifies all nodes in current cluster topology support BaselineTopology feature so compatibilityMode flag is
464- * enabled to reset.
465- *
466- * @param discoCache
467- */
468- private void verifyBaselineTopologySupport (DiscoCache discoCache ) {
469- if (discoCache .minimumServerNodeVersion ().compareTo (MIN_BLT_SUPPORTING_VER ) < 0 ) {
470- SB sb = new SB ("Cluster contains nodes that don't support BaselineTopology: [" );
471-
472- for (ClusterNode cn : discoCache .serverNodes ()) {
473- if (cn .version ().compareTo (MIN_BLT_SUPPORTING_VER ) < 0 )
474- sb
475- .a ("[" )
476- .a (cn .consistentId ())
477- .a (":" )
478- .a (cn .version ())
479- .a ("], " );
480- }
481-
482- sb .d (sb .length () - 2 , sb .length ());
483-
484- throw new IgniteException (sb .a ("]" ).toString ());
485- }
486- }
487-
488456 /**
489457 * Executes validation checks of cluster state and BaselineTopology before changing BaselineTopology to new one.
490458 */
491459 private void validateBeforeBaselineChange (Collection <? extends BaselineNode > baselineTop ) {
492- verifyBaselineTopologySupport (ctx .discovery ().discoCache ());
493-
494460 if (!ctx .state ().clusterState ().active ())
495461 throw new IgniteException ("Changing BaselineTopology on inactive cluster is not allowed." );
496462
0 commit comments