diff options
author | Harald Musum <musum@yahooinc.com> | 2022-03-18 06:48:24 +0100 |
---|---|---|
committer | Harald Musum <musum@yahooinc.com> | 2022-03-18 06:48:24 +0100 |
commit | a0ffdbc4e99c737323395f50249a4f76918198b4 (patch) | |
tree | ad2e8bf3e6d1676ff4737b15dc63b19cfc1bcfec /node-repository/src/main/java/com/yahoo/vespa/hosted/provision/maintenance/MetricsReporter.java | |
parent | 9457a53d04f774a40853401a24659e8f992fb5ea (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.java | 6 |
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) { |