Correct version check with 3.0.0

Signed-off-by: Aman Khare <[email protected]>
Gaurav614 · Mar 13, 2024 · d3b1140 · d3b1140
1 parent 1574fc2
commit d3b1140
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/server/src/main/java/org/opensearch/cluster/routing/allocation/AllocationService.java b/server/src/main/java/org/opensearch/cluster/routing/allocation/AllocationService.java
@@ -570,7 +570,7 @@ private void allocateExistingUnassignedShards(RoutingAllocation allocation) {
          Use batch mode if enabled and there is no custom allocator set for Allocation service
          */
         Boolean batchModeEnabled = EXISTING_SHARDS_ALLOCATOR_BATCH_MODE.get(settings);
-        if (batchModeEnabled && allocation.nodes().getMinNodeVersion().onOrAfter(Version.CURRENT) && existingShardsAllocators.size() == 2) {
+        if (batchModeEnabled && allocation.nodes().getMinNodeVersion().onOrAfter(Version.V_3_0_0) && existingShardsAllocators.size() == 2) {
             /*
              If we do not have any custom allocator set then we will be using ShardsBatchGatewayAllocator
              Currently AllocationService will not run any custom Allocator that implements allocateAllUnassignedShards