Module org.elasticsearch.server
Class CompatibilityVersionsFixupListener
java.lang.Object
org.elasticsearch.cluster.service.CompatibilityVersionsFixupListener
- All Implemented Interfaces:
ClusterStateListener
This fixes up the compatibility versions (transport version and system index mapping versions) in cluster state.
Transport version from pre-8.8.0 cluster state was inferred as the minimum possible,
due to the master node not understanding cluster state with transport versions added in 8.8.0.
Any nodes with the inferred placeholder cluster state is then refreshed with their actual transport version.
Same for system index mapping versions: when upgraded from pre-8.11.0, cluster state holds and empty map of system index mapping
versions. Any nodes with an empty system index mapping versions map in cluster state is refreshed with their actual versions.
-
Constructor Summary
ConstructorsConstructorDescriptionCompatibilityVersionsFixupListener(ClusterService service, ClusterAdminClient client, FeatureService featureService, ThreadPool threadPool) -
Method Summary
Modifier and TypeMethodDescriptionvoidCalled when cluster state changes.
-
Constructor Details
-
CompatibilityVersionsFixupListener
public CompatibilityVersionsFixupListener(ClusterService service, ClusterAdminClient client, FeatureService featureService, ThreadPool threadPool)
-
-
Method Details
-
clusterChanged
Description copied from interface:ClusterStateListenerCalled when cluster state changes.Cluster states are applied one-by-one which means they can be a performance bottleneck. Implementations of this method should therefore be fast, so please consider forking work into the background rather than doing everything inline.
- Specified by:
clusterChangedin interfaceClusterStateListener
-