[ML] Remove the cluster state listener when the adaptive allocations …

…service stops (elastic#113524)
pmpailis · Sep 25, 2024 · a34e9fc · a34e9fc
1 parent 328f463
commit a34e9fc
Showing 1 changed file with 5 additions and 0 deletions.
diff --git a/...lasticsearch/xpack/ml/inference/adaptiveallocations/AdaptiveAllocationsScalerService.java b/...lasticsearch/xpack/ml/inference/adaptiveallocations/AdaptiveAllocationsScalerService.java
@@ -259,12 +259,17 @@ public synchronized void start() {
     }
 
     public synchronized void stop() {
+        clusterService.removeListener(this);
         stopScheduling();
         metrics.close();
     }
 
     @Override
     public void clusterChanged(ClusterChangedEvent event) {
+        if (event.metadataChanged() == false) {
+            return;
+        }
+
         updateAutoscalers(event.state());
         if (scalers.isEmpty() == false) {
             startScheduling();