Class CompatibilityVersionsFixupListener

java.lang.Object
org.elasticsearch.cluster.service.CompatibilityVersionsFixupListener
All Implemented Interfaces:
ClusterStateListener

public class CompatibilityVersionsFixupListener extends Object implements 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 Details

  • Method Details

    • clusterChanged

      public void clusterChanged(ClusterChangedEvent event)
      Description copied from interface: ClusterStateListener
      Called 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:
      clusterChanged in interface ClusterStateListener