diff --git a/x-pack/plugin/ml/src/main/java/org/elasticsearch/xpack/ml/autoscaling/MlAutoscalingDeciderService.java b/x-pack/plugin/ml/src/main/java/org/elasticsearch/xpack/ml/autoscaling/MlAutoscalingDeciderService.java index 8c3b3df423c85..39913e3e5d879 100644 --- a/x-pack/plugin/ml/src/main/java/org/elasticsearch/xpack/ml/autoscaling/MlAutoscalingDeciderService.java +++ b/x-pack/plugin/ml/src/main/java/org/elasticsearch/xpack/ml/autoscaling/MlAutoscalingDeciderService.java @@ -342,7 +342,7 @@ public AutoscalingDeciderResult scale(Settings configuration, AutoscalingDecider "view of job memory is stale given duration [{}]. Not attempting to make scaling decision", mlMemoryTracker.getStalenessDuration() ); - return buildDecisionAndRequestRefresh(reasonBuilder); + return buildDecisionAndRequestRefresh(reasonBuilder.setSimpleReason(MEMORY_STALE)); } // We need the current node loads to determine if we need to scale up or down List nodeLoads = new ArrayList<>(mlNodes.size()); @@ -1037,7 +1037,7 @@ Optional calculateFutureAvailableCapacity(PersistentTasksC private AutoscalingDeciderResult buildDecisionAndRequestRefresh(MlScalingReason.Builder reasonBuilder) { mlMemoryTracker.asyncRefresh(); - return new AutoscalingDeciderResult(null, reasonBuilder.setSimpleReason(MEMORY_STALE).build()); + return new AutoscalingDeciderResult(null, reasonBuilder.build()); } private Long getAnalyticsMemoryRequirement(String analyticsId) {