aboutsummaryrefslogtreecommitdiffstats
path: root/node-repository/src/main/java/com/yahoo/vespa/hosted/provision/maintenance/MetricsReporter.java
diff options
context:
space:
mode:
authorHarald Musum <musum@yahooinc.com>2022-03-18 06:48:24 +0100
committerHarald Musum <musum@yahooinc.com>2022-03-18 06:48:24 +0100
commita0ffdbc4e99c737323395f50249a4f76918198b4 (patch)
treead2e8bf3e6d1676ff4737b15dc63b19cfc1bcfec /node-repository/src/main/java/com/yahoo/vespa/hosted/provision/maintenance/MetricsReporter.java
parent9457a53d04f774a40853401a24659e8f992fb5ea (diff)
Consider architecture when calculating with NodeResources
Diffstat (limited to 'node-repository/src/main/java/com/yahoo/vespa/hosted/provision/maintenance/MetricsReporter.java')
-rw-r--r--node-repository/src/main/java/com/yahoo/vespa/hosted/provision/maintenance/MetricsReporter.java6
1 files changed, 3 insertions, 3 deletions
diff --git a/node-repository/src/main/java/com/yahoo/vespa/hosted/provision/maintenance/MetricsReporter.java b/node-repository/src/main/java/com/yahoo/vespa/hosted/provision/maintenance/MetricsReporter.java
index 636884cef0a..1fe29c8b162 100644
--- a/node-repository/src/main/java/com/yahoo/vespa/hosted/provision/maintenance/MetricsReporter.java
+++ b/node-repository/src/main/java/com/yahoo/vespa/hosted/provision/maintenance/MetricsReporter.java
@@ -343,7 +343,7 @@ public class MetricsReporter extends NodeRepositoryMaintainer {
(applicationId, applicationNodes) -> {
var allocatedCapacity = applicationNodes.stream()
.map(node -> node.allocation().get().requestedResources().justNumbers())
- .reduce(new NodeResources(0, 0, 0, 0, any), NodeResources::add);
+ .reduce(new NodeResources(0, 0, 0, 0, any).justNumbers(), NodeResources::add);
var context = getContext(dimensions(applicationId));
@@ -379,14 +379,14 @@ public class MetricsReporter extends NodeRepositoryMaintainer {
return nodes.hosts().state(State.active).asList().stream()
.map(host -> host.flavor().resources())
.map(NodeResources::justNumbers)
- .reduce(new NodeResources(0, 0, 0, 0, any), NodeResources::add);
+ .reduce(new NodeResources(0, 0, 0, 0, any).justNumbers(), NodeResources::add);
}
private static NodeResources getFreeCapacityTotal(NodeList nodes) {
return nodes.hosts().state(State.active).asList().stream()
.map(n -> freeCapacityOf(nodes, n))
.map(NodeResources::justNumbers)
- .reduce(new NodeResources(0, 0, 0, 0, any), NodeResources::add);
+ .reduce(new NodeResources(0, 0, 0, 0, any).justNumbers(), NodeResources::add);
}
private static NodeResources freeCapacityOf(NodeList nodes, Node host) {