Updated settings name and added warn logs

Signed-off-by: Gaurav Chandani <[email protected]>
Gaurav614 · Jan 11, 2024 · 77f555a · 77f555a
1 parent 2591513
commit 77f555a
Show file tree

Hide file tree

Showing 2 changed files with 2 additions 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
@@ -577,6 +577,7 @@ private void allocateExistingUnassignedShards(RoutingAllocation allocation) {
             allocator.allocateUnassignedBatch(allocation, false);
             return;
         }
+        logger.warn("Falling back to single shard assignment since batch mode disable or multiple custom allocators set");
 
         final RoutingNodes.UnassignedShards.UnassignedIterator primaryIterator = allocation.routingNodes().unassigned().iterator();
         while (primaryIterator.hasNext()) {

diff --git a/server/src/main/java/org/opensearch/cluster/routing/allocation/ExistingShardsAllocator.java b/server/src/main/java/org/opensearch/cluster/routing/allocation/ExistingShardsAllocator.java
@@ -79,7 +79,7 @@ public interface ExistingShardsAllocator {
      * https://github.com/opensearch-project/OpenSearch/issues/5098
      */
     Setting<Boolean> EXISTING_SHARDS_ALLOCATOR_BATCH_MODE = Setting.boolSetting(
-        "cluster.allocator.existing_shards_allocator.batch_enable",
+        "cluster.allocator.existing_shards_allocator.batch_enabled",
         true,
         Setting.Property.NodeScope
     );