diff options
author | Valerij Fredriksen <freva@users.noreply.github.com> | 2023-06-01 17:24:25 +0200 |
---|---|---|
committer | GitHub <noreply@github.com> | 2023-06-01 17:24:25 +0200 |
commit | e985c95958a722691b72ac89fd0ba6766ae45083 (patch) | |
tree | 1af2e22c0308bac54870a74a7f479f2b6a133e3a | |
parent | 564d0189caecf39c545880727cd07acc62c52785 (diff) | |
parent | cdbaa17019be02605888af51e211972fde096a8b (diff) |
Merge pull request #27261 from vespa-engine/jonmv/convert-to-advertised-resources
Compare advertised resrouces to candidate node
-rw-r--r-- | node-repository/src/main/java/com/yahoo/vespa/hosted/provision/provisioning/NodePrioritizer.java | 4 |
1 files changed, 3 insertions, 1 deletions
diff --git a/node-repository/src/main/java/com/yahoo/vespa/hosted/provision/provisioning/NodePrioritizer.java b/node-repository/src/main/java/com/yahoo/vespa/hosted/provision/provisioning/NodePrioritizer.java index 1d4ab5fc09c..4f21c8dcd50 100644 --- a/node-repository/src/main/java/com/yahoo/vespa/hosted/provision/provisioning/NodePrioritizer.java +++ b/node-repository/src/main/java/com/yahoo/vespa/hosted/provision/provisioning/NodePrioritizer.java @@ -32,6 +32,7 @@ public class NodePrioritizer { private final List<NodeCandidate> candidates = new ArrayList<>(); private final LockedNodeList allNodes; private final HostCapacity capacity; + private final HostResourcesCalculator calculator; private final NodeSpec requestedNodes; private final ApplicationId application; private final ClusterSpec clusterSpec; @@ -48,6 +49,7 @@ public class NodePrioritizer { int wantedGroups, boolean dynamicProvisioning, NameResolver nameResolver, Nodes nodes, HostResourcesCalculator hostResourcesCalculator, int spareCount, boolean enclave) { this.allNodes = allNodes; + this.calculator = hostResourcesCalculator; this.capacity = new HostCapacity(this.allNodes, hostResourcesCalculator); this.requestedNodes = nodeSpec; this.clusterSpec = clusterSpec; @@ -155,7 +157,7 @@ public class NodePrioritizer { } private boolean fitsPerfectly(Node host) { - return host.resources().compatibleWith(requestedNodes.resources().get()); + return calculator.advertisedResourcesOf(host.flavor()).compatibleWith(requestedNodes.resources().get()); } /** Add existing nodes allocated to the application */ |