aboutsummaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authorJon Bratseth <bratseth@gmail.com>2022-02-27 16:38:02 +0100
committerJon Bratseth <bratseth@gmail.com>2022-02-27 16:38:02 +0100
commitd34904697419c851e4457120b823cc3b5c84b094 (patch)
tree3cf7139791bb364c63051c4bd38b708436e41515
parentd00919409df940b84bdb612bc3e27e11e8c0de4f (diff)
Use flag source ref from node repo
-rw-r--r--node-repository/src/main/java/com/yahoo/vespa/hosted/provision/provisioning/NodeRepositoryProvisioner.java6
1 files changed, 3 insertions, 3 deletions
diff --git a/node-repository/src/main/java/com/yahoo/vespa/hosted/provision/provisioning/NodeRepositoryProvisioner.java b/node-repository/src/main/java/com/yahoo/vespa/hosted/provision/provisioning/NodeRepositoryProvisioner.java
index d890c144fd6..4dc199dd7b2 100644
--- a/node-repository/src/main/java/com/yahoo/vespa/hosted/provision/provisioning/NodeRepositoryProvisioner.java
+++ b/node-repository/src/main/java/com/yahoo/vespa/hosted/provision/provisioning/NodeRepositoryProvisioner.java
@@ -56,7 +56,6 @@ public class NodeRepositoryProvisioner implements Provisioner {
private final AllocationOptimizer allocationOptimizer;
private final CapacityPolicies capacityPolicies;
private final Zone zone;
- private FlagSource flagSource;
private final Preparer preparer;
private final Activator activator;
private final Optional<LoadBalancerProvisioner> loadBalancerProvisioner;
@@ -71,7 +70,6 @@ public class NodeRepositoryProvisioner implements Provisioner {
this.allocationOptimizer = new AllocationOptimizer(nodeRepository);
this.capacityPolicies = new CapacityPolicies(nodeRepository);
this.zone = zone;
- this.flagSource = flagSource;
this.loadBalancerProvisioner = provisionServiceProvider.getLoadBalancerService(nodeRepository)
.map(lbService -> new LoadBalancerProvisioner(nodeRepository, lbService));
this.nodeResourceLimits = new NodeResourceLimits(nodeRepository);
@@ -118,7 +116,9 @@ public class NodeRepositoryProvisioner implements Provisioner {
: requested.minResources().nodeResources();
nodeSpec = NodeSpec.from(requested.type());
}
- var reuseIndexes = Flags.REUSE_NODE_INDEXES.bindTo(flagSource).with(FetchVector.Dimension.ZONE_ID, zone.systemLocalValue()).value();
+ var reuseIndexes = Flags.REUSE_NODE_INDEXES.bindTo(nodeRepository.flagSource())
+ .with(FetchVector.Dimension.ZONE_ID, zone.systemLocalValue())
+ .value();
return asSortedHosts(preparer.prepare(application, cluster, nodeSpec, groups, reuseIndexes), resources);
}