Adding min version check

rajiv-kv · Feb 8, 2024 · b9f9f2a · b9f9f2a
1 parent 16d8152
commit b9f9f2a
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/.../java/org/opensearch/action/support/clustermanager/TransportClusterManagerNodeAction.java b/.../java/org/opensearch/action/support/clustermanager/TransportClusterManagerNodeAction.java
@@ -35,6 +35,7 @@
 import org.apache.logging.log4j.LogManager;
 import org.apache.logging.log4j.Logger;
 import org.apache.logging.log4j.message.ParameterizedMessage;
+import org.opensearch.Version;
 import org.opensearch.action.ActionListenerResponseHandler;
 import org.opensearch.action.ActionRunnable;
 import org.opensearch.action.admin.cluster.state.term.ClusterTermVersionAction;
@@ -264,7 +265,7 @@ protected void doStart(ClusterState clusterState) {
                     } else {
                         DiscoveryNode clusterManagerNode = nodes.getClusterManagerNode();
 
-                        if (checkTermVersion()) {
+                        if (clusterManagerNode.getVersion().onOrAfter(Version.V_2_11_0) && checkTermVersion()) {
                             transportService.sendRequest(
                                 clusterManagerNode,
                                 ClusterTermVersionAction.NAME,