diff options
Diffstat (limited to 'node-repository/src/main/java/com/yahoo/vespa/hosted/provision/autoscale/Autoscaler.java')
-rw-r--r-- | node-repository/src/main/java/com/yahoo/vespa/hosted/provision/autoscale/Autoscaler.java | 15 |
1 files changed, 6 insertions, 9 deletions
diff --git a/node-repository/src/main/java/com/yahoo/vespa/hosted/provision/autoscale/Autoscaler.java b/node-repository/src/main/java/com/yahoo/vespa/hosted/provision/autoscale/Autoscaler.java index 35db29d6f8c..321340331b1 100644 --- a/node-repository/src/main/java/com/yahoo/vespa/hosted/provision/autoscale/Autoscaler.java +++ b/node-repository/src/main/java/com/yahoo/vespa/hosted/provision/autoscale/Autoscaler.java @@ -67,23 +67,20 @@ public class Autoscaler { if (scaledIn(clusterModel.scalingDuration(), cluster)) return Advice.dontScale("Won't autoscale now: Less than " + clusterModel.scalingDuration() + " since last resource change"); - var clusterNodesTimeseries = new ClusterNodesTimeseries(clusterModel.scalingDuration(), cluster, clusterNodes, metricsDb); - var currentAllocation = new AllocatableClusterResources(clusterNodes.asList(), nodeRepository, cluster.exclusive()); - - int measurementsPerNode = clusterNodesTimeseries.measurementsPerNode(); - if (measurementsPerNode < minimumMeasurementsPerNode(clusterModel.scalingDuration())) + if (clusterModel.nodeTimeseries().measurementsPerNode() < minimumMeasurementsPerNode(clusterModel.scalingDuration())) return Advice.none("Collecting more data before making new scaling decisions: Need to measure for " + clusterModel.scalingDuration() + " since the last resource change completed"); - int nodesMeasured = clusterNodesTimeseries.nodesMeasured(); - if (nodesMeasured != clusterNodes.size()) + if (clusterModel.nodeTimeseries().nodesMeasured() != clusterNodes.size()) return Advice.none("Collecting more data before making new scaling decisions: " + - "Have measurements from " + nodesMeasured + " nodes, but require from " + clusterNodes.size()); + "Have measurements from " + clusterModel.nodeTimeseries().nodesMeasured() + + " nodes, but require from " + clusterNodes.size()); + var currentAllocation = new AllocatableClusterResources(clusterNodes.asList(), nodeRepository, cluster.exclusive()); var clusterTimeseries = metricsDb.getClusterTimeseries(application.id(), cluster.id()); var target = ResourceTarget.idealLoad(clusterModel.scalingDuration(), clusterTimeseries, - clusterNodesTimeseries, + clusterModel.nodeTimeseries(), currentAllocation, application, nodeRepository.clock()); |