Modify GA to use batchMode flag

Signed-off-by: Shivansh Arora <[email protected]>
shiv0408 · Nov 30, 2023 · a730ff5 · a730ff5
1 parent 354a945
commit a730ff5
Showing 1 changed file with 1 addition and 2 deletions.
diff --git a/server/src/main/java/org/opensearch/gateway/GatewayAllocator.java b/server/src/main/java/org/opensearch/gateway/GatewayAllocator.java
@@ -199,8 +199,7 @@ protected static void innerAllocatedUnassigned(
     public AllocateUnassignedDecision explainUnassignedShardAllocation(ShardRouting unassignedShard, RoutingAllocation routingAllocation) {
         assert unassignedShard.unassigned();
         assert routingAllocation.debugDecision();
-        boolean batchMode = routingAllocation.nodes().getMinNodeVersion().onOrAfter(Version.CURRENT);
-        if (batchMode) {
+        if (this.batchMode) {
             if (getBatchId(unassignedShard, unassignedShard.primary()) == null) {
                 createAndUpdateBatches(routingAllocation, unassignedShard.primary());
             }