Gather system index mappings versions when a capable node becomes master

williamrandolph · Dec 5, 2023 · ec18558 · ec18558
1 parent e842463
commit ec18558
Showing 1 changed file with 5 additions and 0 deletions.
diff --git a/server/src/main/java/org/elasticsearch/cluster/coordination/NodeJoinExecutor.java b/server/src/main/java/org/elasticsearch/cluster/coordination/NodeJoinExecutor.java
@@ -155,6 +155,11 @@ public ClusterState execute(BatchExecutionContext<JoinTask> batchExecutionContex
                         nodeFeatures.put(node.getId(), nodeJoinTask.features());
                         nodesChanged = true;
                     }
+                    if (Objects.equals(compatibilityVersionsMap.get(node.getId()), nodeJoinTask.compatibilityVersions()) == false) {
+                        logger.debug("updating node [{}] compatibility versions {}", node.getId(), nodeJoinTask.compatibilityVersions());
+                        compatibilityVersionsMap.put(node.getId(), nodeJoinTask.compatibilityVersions());
+                        nodesChanged = true;
+                    }
                 } else {
                     try {
                         CompatibilityVersions compatibilityVersions = nodeJoinTask.compatibilityVersions();