From 17354932c6244b84ee6d38cabccb56df5ca0ec21 Mon Sep 17 00:00:00 2001 From: Pranoti27 Date: Fri, 9 Jan 2026 12:01:47 -0800 Subject: [PATCH] Remove admin_state check from computing actual allocations --- .../allocation/ActualAllocationUpdater.java | 7 ------- .../allocation/ActualAllocationUpdaterCleanupTest.java | 1 - 2 files changed, 8 deletions(-) diff --git a/src/main/java/io/clustercontroller/allocation/ActualAllocationUpdater.java b/src/main/java/io/clustercontroller/allocation/ActualAllocationUpdater.java index 829e7d9..3414e23 100644 --- a/src/main/java/io/clustercontroller/allocation/ActualAllocationUpdater.java +++ b/src/main/java/io/clustercontroller/allocation/ActualAllocationUpdater.java @@ -102,13 +102,6 @@ private Map>> collectActualAllocations(String cl String unitName = searchUnit.getName(); try { - // First check if the search unit itself is DRAINED or unhealthy in configuration - if (!Constants.ADMIN_STATE_NORMAL.equalsIgnoreCase(String.valueOf(searchUnit.getStateAdmin()))) { - log.debug("ActualAllocationUpdater - Skipping non-normal SU: {} (admin_state: {})", - unitName, searchUnit.getStateAdmin()); - continue; - } - // Skip coordinator nodes - they belong to a separate cluster if (isCoordinatorNode(searchUnit)) { log.debug("ActualAllocationUpdater - Skipping coordinator node: {}", unitName); diff --git a/src/test/java/io/clustercontroller/allocation/ActualAllocationUpdaterCleanupTest.java b/src/test/java/io/clustercontroller/allocation/ActualAllocationUpdaterCleanupTest.java index b18ba2f..ea39425 100644 --- a/src/test/java/io/clustercontroller/allocation/ActualAllocationUpdaterCleanupTest.java +++ b/src/test/java/io/clustercontroller/allocation/ActualAllocationUpdaterCleanupTest.java @@ -202,7 +202,6 @@ private Index createIndex(String indexName, int numberOfShards) { private SearchUnit createSearchUnit(String unitName) { SearchUnit unit = new SearchUnit(); unit.setName(unitName); - unit.setStateAdmin("NORMAL"); // Required for collectActualAllocations return unit; }