summaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authorValerij Fredriksen <freva@users.noreply.github.com>2023-06-01 17:24:25 +0200
committerGitHub <noreply@github.com>2023-06-01 17:24:25 +0200
commite985c95958a722691b72ac89fd0ba6766ae45083 (patch)
tree1af2e22c0308bac54870a74a7f479f2b6a133e3a
parent564d0189caecf39c545880727cd07acc62c52785 (diff)
parentcdbaa17019be02605888af51e211972fde096a8b (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.java4
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 */