summaryrefslogtreecommitdiffstats
path: root/node-repository
diff options
context:
space:
mode:
authorJon Bratseth <bratseth@gmail.com>2020-09-08 12:25:36 +0200
committerJon Bratseth <bratseth@gmail.com>2020-09-08 12:25:36 +0200
commit4e0bddc561f97402f719209fa595c6d760564f9f (patch)
tree5844e46df753c049962cd6c513dd0a87f316c061 /node-repository
parent5b2f64a6591c61dc1a6ba1d4653f5316e17adcdd (diff)
Log current resourtces more accurately
Use the average resource calculation in AllocatableClusterResources to log current resources more accurately.
Diffstat (limited to 'node-repository')
-rw-r--r--node-repository/src/main/java/com/yahoo/vespa/hosted/provision/maintenance/AutoscalingMaintainer.java14
1 files changed, 7 insertions, 7 deletions
diff --git a/node-repository/src/main/java/com/yahoo/vespa/hosted/provision/maintenance/AutoscalingMaintainer.java b/node-repository/src/main/java/com/yahoo/vespa/hosted/provision/maintenance/AutoscalingMaintainer.java
index 572fab44418..ddee1afe21e 100644
--- a/node-repository/src/main/java/com/yahoo/vespa/hosted/provision/maintenance/AutoscalingMaintainer.java
+++ b/node-repository/src/main/java/com/yahoo/vespa/hosted/provision/maintenance/AutoscalingMaintainer.java
@@ -12,6 +12,7 @@ import com.yahoo.vespa.hosted.provision.NodeRepository;
import com.yahoo.vespa.hosted.provision.applications.Application;
import com.yahoo.vespa.hosted.provision.applications.Applications;
import com.yahoo.vespa.hosted.provision.applications.Cluster;
+import com.yahoo.vespa.hosted.provision.autoscale.AllocatableClusterResources;
import com.yahoo.vespa.hosted.provision.autoscale.Autoscaler;
import com.yahoo.vespa.hosted.provision.autoscale.NodeMetricsDb;
@@ -84,19 +85,18 @@ public class AutoscalingMaintainer extends NodeRepositoryMaintainer {
ApplicationId application,
ClusterSpec.Id clusterId,
List<Node> clusterNodes) {
- int currentGroups = (int)clusterNodes.stream().map(node -> node.allocation().get().membership().cluster().group()).distinct().count();
+ ClusterResources current = new AllocatableClusterResources(clusterNodes, nodeRepository()).toAdvertisedClusterResources();
ClusterSpec.Type clusterType = clusterNodes.get(0).allocation().get().membership().cluster().type();
log.info("Autoscaling " + application + " " + clusterType + " " + clusterId + ":" +
- "\nfrom " + toString(clusterNodes.size(), currentGroups, clusterNodes.get(0).resources()) +
- "\nto " + toString(target.nodes(), target.groups(), target.nodeResources()));
+ "\nfrom " + toString(current) + "\nto " + toString(target));
}
- private String toString(int nodes, int groups, NodeResources resources) {
- return String.format(nodes + (groups > 1 ? " (in " + groups + " groups)" : "") +
+ private String toString(ClusterResources r) {
+ return String.format(r.nodes() + (r.groups() > 1 ? " (in " + r.groups() + " groups)" : "") +
" * [vcpu: %0$.1f, memory: %1$.1f Gb, disk %2$.1f Gb]" +
" (total: [vcpu: %3$.1f, memory: %4$.1f Gb, disk: %5$.1f Gb])",
- resources.vcpu(), resources.memoryGb(), resources.diskGb(),
- nodes * resources.vcpu(), nodes * resources.memoryGb(), nodes * resources.diskGb());
+ r.nodeResources().vcpu(), r.nodeResources().memoryGb(), r.nodeResources().diskGb(),
+ r.nodes() * r.nodeResources().vcpu(), r.nodes() * r.nodeResources().memoryGb(), r.nodes() * r.nodeResources().diskGb());
}
private Map<ClusterSpec.Id, List<Node>> nodesByCluster(List<Node> applicationNodes) {