diff options
author | Jon Bratseth <bratseth@verizonmedia.com> | 2019-08-14 14:45:11 +0200 |
---|---|---|
committer | Jon Bratseth <bratseth@verizonmedia.com> | 2019-08-14 14:45:11 +0200 |
commit | a8ed8292f49c953bb0f01a2c9602d7bcda7c2244 (patch) | |
tree | 63f16874dec36a13c82828e4762ff6415c29e9a2 | |
parent | ec5201a3396ae573e6ace8660c24db18daad7791 (diff) |
Remove handling of legacy flavor allocations
17 files changed, 50 insertions, 125 deletions
diff --git a/config-model/src/test/java/com/yahoo/vespa/model/test/VespaModelTester.java b/config-model/src/test/java/com/yahoo/vespa/model/test/VespaModelTester.java index 6d0c2c6abde..3f82a668fd0 100644 --- a/config-model/src/test/java/com/yahoo/vespa/model/test/VespaModelTester.java +++ b/config-model/src/test/java/com/yahoo/vespa/model/test/VespaModelTester.java @@ -81,10 +81,9 @@ public class VespaModelTester { // This allows us to test index vs. name order selection when subsets of hosts are selected from a cluster // (for e.g cluster controllers and slobrok nodes) String hostname = String.format("%s-%02d", - resources.allocateByLegacyName() ? resources.legacyName().get() : "node" + - "-" + Math.round(resources.vcpu()) + - "-" + Math.round(resources.memoryGb()) + - "-" + Math.round(resources.diskGb()), + "node" + "-" + Math.round(resources.vcpu()) + + "-" + Math.round(resources.memoryGb()) + + "-" + Math.round(resources.diskGb()), count - i); hosts.add(new Host(hostname, ImmutableList.of(), flavor)); } diff --git a/config-provisioning/src/main/java/com/yahoo/config/provision/Flavor.java b/config-provisioning/src/main/java/com/yahoo/config/provision/Flavor.java index a05d4382026..7cac2800449 100644 --- a/config-provisioning/src/main/java/com/yahoo/config/provision/Flavor.java +++ b/config-provisioning/src/main/java/com/yahoo/config/provision/Flavor.java @@ -47,9 +47,6 @@ public class Flavor { /** Creates a *node* flavor from a node resources spec */ public Flavor(NodeResources resources) { Objects.requireNonNull(resources, "Resources cannot be null"); - if (resources.allocateByLegacyName()) - throw new IllegalArgumentException("Can not create flavor '" + resources.legacyName() + "' from a flavor: " + - "Non-docker flavors must be of a configured flavor"); this.configured = false; this.name = resources.legacyName().orElse(resources.toString()); this.cost = 0; diff --git a/config-provisioning/src/main/java/com/yahoo/config/provision/NodeFlavors.java b/config-provisioning/src/main/java/com/yahoo/config/provision/NodeFlavors.java index 4d4d3c8cf86..5dbfc413de4 100644 --- a/config-provisioning/src/main/java/com/yahoo/config/provision/NodeFlavors.java +++ b/config-provisioning/src/main/java/com/yahoo/config/provision/NodeFlavors.java @@ -41,10 +41,7 @@ public class NodeFlavors { return Optional.of(configuredFlavors.get(name)); NodeResources nodeResources = NodeResources.fromLegacyName(name); - if (nodeResources.allocateByLegacyName()) - return Optional.empty(); - else - return Optional.of(new Flavor(nodeResources)); + return Optional.of(new Flavor(nodeResources)); } /** diff --git a/config-provisioning/src/main/java/com/yahoo/config/provision/NodeResources.java b/config-provisioning/src/main/java/com/yahoo/config/provision/NodeResources.java index a14ab9e432a..da7050a3187 100644 --- a/config-provisioning/src/main/java/com/yahoo/config/provision/NodeResources.java +++ b/config-provisioning/src/main/java/com/yahoo/config/provision/NodeResources.java @@ -22,8 +22,6 @@ public class NodeResources { private final double diskGb; private final DiskSpeed diskSpeed; - private final boolean allocateByLegacyName; - /** The legacy (flavor) name of this, or null if none */ private final String legacyName; @@ -37,17 +35,14 @@ public class NodeResources { this.memoryGb = memoryGb; this.diskGb = diskGb; this.diskSpeed = diskSpeed; - this.allocateByLegacyName = false; this.legacyName = null; } - private NodeResources(double vcpu, double memoryGb, double diskGb, DiskSpeed diskSpeed, - boolean allocateByLegacyName, String legacyName) { + private NodeResources(double vcpu, double memoryGb, double diskGb, DiskSpeed diskSpeed, String legacyName) { this.vcpu = vcpu; this.memoryGb = memoryGb; this.diskGb = diskGb; this.diskSpeed = diskSpeed; - this.allocateByLegacyName = allocateByLegacyName; this.legacyName = legacyName; } @@ -82,24 +77,14 @@ public class NodeResources { combine(this.diskSpeed, other.diskSpeed)); } - /** - * If this is true, a non-docker legacy name was used to specify this and we'll respect that by mapping directly. - * The other getters of this will return 0. - */ - public boolean allocateByLegacyName() { return allocateByLegacyName; } - /** Returns the legacy name of this, or empty if none. */ public Optional<String> legacyName() { return Optional.ofNullable(legacyName); } private boolean isInterchangeableWith(NodeResources other) { - if (this.allocateByLegacyName != other.allocateByLegacyName) return false; - if (this.allocateByLegacyName) return legacyName.equals(other.legacyName); - if (this.diskSpeed != DiskSpeed.any && other.diskSpeed != DiskSpeed.any && this.diskSpeed != other.diskSpeed) return false; - return true; } @@ -115,40 +100,26 @@ public class NodeResources { if (o == this) return true; if ( ! (o instanceof NodeResources)) return false; NodeResources other = (NodeResources)o; - if (allocateByLegacyName) { - return this.legacyName.equals(other.legacyName); - } - else { - if (this.vcpu != other.vcpu) return false; - if (this.memoryGb != other.memoryGb) return false; - if (this.diskGb != other.diskGb) return false; - if (this.diskSpeed != other.diskSpeed) return false; - return true; - } + if (this.vcpu != other.vcpu) return false; + if (this.memoryGb != other.memoryGb) return false; + if (this.diskGb != other.diskGb) return false; + if (this.diskSpeed != other.diskSpeed) return false; + return true; } @Override public int hashCode() { - if (allocateByLegacyName) - return legacyName.hashCode(); - else - return (int)(2503 * vcpu + 22123 * memoryGb + 26987 * diskGb + diskSpeed.hashCode()); + return (int)(2503 * vcpu + 22123 * memoryGb + 26987 * diskGb + diskSpeed.hashCode()); } @Override public String toString() { - if (allocateByLegacyName) - return "flavor '" + legacyName + "'"; - else - return "[vcpu: " + vcpu + ", memory: " + memoryGb + " Gb, disk " + diskGb + " Gb" + - (diskSpeed != DiskSpeed.fast ? ", disk speed: " + diskSpeed : "") + "]"; + return "[vcpu: " + vcpu + ", memory: " + memoryGb + " Gb, disk " + diskGb + " Gb" + + (diskSpeed != DiskSpeed.fast ? ", disk speed: " + diskSpeed : "") + "]"; } /** Returns true if all the resources of this are the same or larger than the given resources */ public boolean satisfies(NodeResources other) { - if (this.allocateByLegacyName || other.allocateByLegacyName) // resources are not available - return Objects.equals(this.legacyName, other.legacyName); - if (this.vcpu < other.vcpu) return false; if (this.memoryGb < other.memoryGb) return false; if (this.diskGb < other.diskGb) return false; @@ -163,9 +134,6 @@ public class NodeResources { /** Returns true if all the resources of this are the same as or compatible with the given resources */ public boolean compatibleWith(NodeResources other) { - if (this.allocateByLegacyName || other.allocateByLegacyName) // resources are not available - return Objects.equals(this.legacyName, other.legacyName); - if (this.vcpu != other.vcpu) return false; if (this.memoryGb != other.memoryGb) return false; if (this.diskGb != other.diskGb) return false; @@ -192,7 +160,7 @@ public class NodeResources { if (cpu == 0) cpu = 0.5; if (cpu == 2 && mem == 8 ) cpu = 1.5; if (cpu == 2 && mem == 12 ) cpu = 2.3; - return new NodeResources(cpu, mem, dsk, DiskSpeed.fast, false, string); + return new NodeResources(cpu, mem, dsk, DiskSpeed.fast, string); } } diff --git a/node-repository/src/main/java/com/yahoo/vespa/hosted/provision/provisioning/CapacityPolicies.java b/node-repository/src/main/java/com/yahoo/vespa/hosted/provision/provisioning/CapacityPolicies.java index 6cee3005e91..64e2df78642 100644 --- a/node-repository/src/main/java/com/yahoo/vespa/hosted/provision/provisioning/CapacityPolicies.java +++ b/node-repository/src/main/java/com/yahoo/vespa/hosted/provision/provisioning/CapacityPolicies.java @@ -7,7 +7,6 @@ import com.yahoo.config.provision.Environment; import com.yahoo.config.provision.NodeResources; import com.yahoo.config.provision.Zone; -import com.yahoo.config.provision.NodeFlavors; import com.yahoo.vespa.flags.FlagSource; import com.yahoo.vespa.flags.Flags; @@ -22,12 +21,10 @@ import java.util.Optional; public class CapacityPolicies { private final Zone zone; - private final NodeFlavors flavors; private final FlagSource flagSource; - public CapacityPolicies(Zone zone, NodeFlavors flavors, FlagSource flagSource) { + public CapacityPolicies(Zone zone, FlagSource flagSource) { this.zone = zone; - this.flavors = flavors; this.flagSource = flagSource; } @@ -45,9 +42,7 @@ public class CapacityPolicies { } public NodeResources decideNodeResources(Optional<NodeResources> requestedResources, ClusterSpec cluster) { - NodeResources resources = specifiedOrDefaultNodeResources(requestedResources, cluster); - - if (resources.allocateByLegacyName()) return resources; // Modification not possible + NodeResources resources = requestedResources.orElse(defaultNodeResources(cluster.type())); // Allow slow disks in zones which are not performance sensitive if (zone.system().isCd() || zone.environment() == Environment.dev || zone.environment() == Environment.test) @@ -60,24 +55,6 @@ public class CapacityPolicies { return resources; } - private NodeResources specifiedOrDefaultNodeResources(Optional<NodeResources> requestedResources, ClusterSpec cluster) { - if (requestedResources.isPresent() && ! requestedResources.get().allocateByLegacyName()) - return requestedResources.get(); - - if (requestedResources.isEmpty()) - return defaultNodeResources(cluster.type()); - - switch (zone.environment()) { - case dev: case test: case staging: return defaultNodeResources(cluster.type()); - default: - flavors.getFlavorOrThrow(requestedResources.get().legacyName().get()); // verify existence - // Return this spec containing the legacy flavor name, not the flavor's capacity object - // which describes the flavors capacity, as the point of legacy allocation is to match - // by name, not by resources - return requestedResources.get(); - } - } - private NodeResources defaultNodeResources(ClusterSpec.Type clusterType) { if (clusterType == ClusterSpec.Type.admin) return nodeResourcesForAdminCluster(); diff --git a/node-repository/src/main/java/com/yahoo/vespa/hosted/provision/provisioning/NodeAllocation.java b/node-repository/src/main/java/com/yahoo/vespa/hosted/provision/provisioning/NodeAllocation.java index d4527452e9c..7dca60171a5 100644 --- a/node-repository/src/main/java/com/yahoo/vespa/hosted/provision/provisioning/NodeAllocation.java +++ b/node-repository/src/main/java/com/yahoo/vespa/hosted/provision/provisioning/NodeAllocation.java @@ -287,7 +287,6 @@ class NodeAllocation { .filter(NodeSpec.CountNodeSpec.class::isInstance) .map(NodeSpec.CountNodeSpec.class::cast) .map(spec -> new FlavorCount(spec.resources(), spec.fulfilledDeficitCount(acceptedOfRequestedFlavor))) - .filter(flavorCount -> ! flavorCount.getFlavor().allocateByLegacyName()) .filter(flavorCount -> flavorCount.getCount() > 0); } 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 6b27662448c..f6554b2dede 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 @@ -215,8 +215,7 @@ class NodePrioritizer { private PrioritizableNode toNodePriority(Node node, boolean isSurplusNode, boolean isNewNode) { PrioritizableNode.Builder builder = new PrioritizableNode.Builder(node) .withSurplusNode(isSurplusNode) - .withNewNode(isNewNode) - .withPreferredOnFlavor(preferredOnLegacyFlavor(node)); + .withNewNode(isNewNode); allNodes.parentOf(node).ifPresent(parent -> { builder.withParent(parent).withFreeParentCapacity(capacity.freeCapacityOf(parent, false)); @@ -229,18 +228,6 @@ class NodePrioritizer { return builder.build(); } - /** Needed to handle requests for legacy non-docker nodes only */ - private boolean preferredOnLegacyFlavor(Node node) { - if (requestedNodes instanceof NodeSpec.CountNodeSpec) { - NodeResources requestedNodeResources = ((NodeSpec.CountNodeSpec)requestedNodes).resources(); - if (requestedNodeResources.allocateByLegacyName()) { - Flavor requestedFlavor = flavors.getFlavorOrThrow(requestedNodeResources.legacyName().get()); - return ! requestedFlavor.isStock() && node.flavor().equals(requestedFlavor); - } - } - return false; - } - static boolean isPreferredNodeToBeRelocated(List<Node> nodes, Node node, Node parent) { NodeList list = new NodeList(nodes); return list.childrenOf(parent).asList().stream() @@ -261,8 +248,7 @@ class NodePrioritizer { } private boolean isDocker() { - NodeResources flavor = resources(requestedNodes); - return (flavor != null) && ! flavor.allocateByLegacyName(); + return resources(requestedNodes) != null; } private static int compareForRelocation(Node a, Node b) { 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 1cf5cfbb4f3..29e37b76ac3 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 @@ -57,10 +57,10 @@ public class NodeRepositoryProvisioner implements Provisioner { } @Inject - public NodeRepositoryProvisioner(NodeRepository nodeRepository, NodeFlavors flavors, Zone zone, + public NodeRepositoryProvisioner(NodeRepository nodeRepository, Zone zone, ProvisionServiceProvider provisionServiceProvider, FlagSource flagSource) { this.nodeRepository = nodeRepository; - this.capacityPolicies = new CapacityPolicies(zone, flavors, flagSource); + this.capacityPolicies = new CapacityPolicies(zone, flagSource); this.zone = zone; this.loadBalancerProvisioner = provisionServiceProvider.getLoadBalancerService().map(lbService -> new LoadBalancerProvisioner(nodeRepository, lbService)); this.preparer = new Preparer(nodeRepository, diff --git a/node-repository/src/main/java/com/yahoo/vespa/hosted/provision/provisioning/NodeSpec.java b/node-repository/src/main/java/com/yahoo/vespa/hosted/provision/provisioning/NodeSpec.java index 66a8f2f8f6d..865b643b93b 100644 --- a/node-repository/src/main/java/com/yahoo/vespa/hosted/provision/provisioning/NodeSpec.java +++ b/node-repository/src/main/java/com/yahoo/vespa/hosted/provision/provisioning/NodeSpec.java @@ -92,19 +92,13 @@ public interface NodeSpec { @Override public boolean isCompatible(Flavor flavor, NodeFlavors flavors) { - if (requestedNodeResources.allocateByLegacyName() && flavor.isConfigured()) { - if (flavor.satisfies(flavors.getFlavorOrThrow(requestedNodeResources.legacyName().get()))) + if (flavor.isDocker()) { // Docker nodes can satisfy a request for parts of their resources + if (flavor.resources().compatibleWith(requestedNodeResources)) return true; } - else { - if (flavor.isDocker()) { // Docker nodes can satisfy a request for parts of their resources - if (flavor.resources().compatibleWith(requestedNodeResources)) - return true; - } - else { // Other nodes must be matched exactly - if (requestedNodeResources.equals(flavor.resources())) - return true; - } + else { // Other nodes must be matched exactly + if (requestedNodeResources.equals(flavor.resources())) + return true; } return requestedFlavorCanBeAchievedByResizing(flavor); } diff --git a/node-repository/src/main/java/com/yahoo/vespa/hosted/provision/testutils/MockNodeRepository.java b/node-repository/src/main/java/com/yahoo/vespa/hosted/provision/testutils/MockNodeRepository.java index a586bfa15c2..3da1d14541e 100644 --- a/node-repository/src/main/java/com/yahoo/vespa/hosted/provision/testutils/MockNodeRepository.java +++ b/node-repository/src/main/java/com/yahoo/vespa/hosted/provision/testutils/MockNodeRepository.java @@ -58,7 +58,6 @@ public class MockNodeRepository extends NodeRepository { private void populate() { NodeRepositoryProvisioner provisioner = new NodeRepositoryProvisioner(this, - flavors, Zone.defaultZone(), new MockProvisionServiceProvider(), new InMemoryFlagSource()); diff --git a/node-repository/src/test/java/com/yahoo/vespa/hosted/provision/maintenance/FailedExpirerTest.java b/node-repository/src/test/java/com/yahoo/vespa/hosted/provision/maintenance/FailedExpirerTest.java index 6be03e7969a..89c6ed6aa0d 100644 --- a/node-repository/src/test/java/com/yahoo/vespa/hosted/provision/maintenance/FailedExpirerTest.java +++ b/node-repository/src/test/java/com/yahoo/vespa/hosted/provision/maintenance/FailedExpirerTest.java @@ -49,8 +49,13 @@ import static org.junit.Assert.assertEquals; public class FailedExpirerTest { private static final ApplicationId tenantHostApplicationId = ApplicationId.from("vespa", "zone-app", "default"); - private static final ClusterSpec tenantHostApplicationClusterSpec = ClusterSpec.request( - ClusterSpec.Type.container, ClusterSpec.Id.from("node-admin"), Version.fromString("6.42"), false); + + private static final ClusterSpec tenantHostApplicationClusterSpec = + ClusterSpec.request(ClusterSpec.Type.container, + ClusterSpec.Id.from("node-admin"), + Version.fromString("6.42"), + false); + private static final Capacity tenantHostApplicationCapacity = Capacity.fromRequiredNodeType(NodeType.host); @Test @@ -275,7 +280,7 @@ public class FailedExpirerTest { new MockNameResolver().mockAnyLookup(), DockerImage.fromString("docker-image"), true); - this.provisioner = new NodeRepositoryProvisioner(nodeRepository, nodeFlavors, Zone.defaultZone(), new MockProvisionServiceProvider(), new InMemoryFlagSource()); + this.provisioner = new NodeRepositoryProvisioner(nodeRepository, Zone.defaultZone(), new MockProvisionServiceProvider(), new InMemoryFlagSource()); this.expirer = new FailedExpirer(nodeRepository, zone, clock, Duration.ofMinutes(30)); } diff --git a/node-repository/src/test/java/com/yahoo/vespa/hosted/provision/maintenance/NodeFailTester.java b/node-repository/src/test/java/com/yahoo/vespa/hosted/provision/maintenance/NodeFailTester.java index 4e82bdbfafe..f4b36b12bff 100644 --- a/node-repository/src/test/java/com/yahoo/vespa/hosted/provision/maintenance/NodeFailTester.java +++ b/node-repository/src/test/java/com/yahoo/vespa/hosted/provision/maintenance/NodeFailTester.java @@ -76,7 +76,7 @@ public class NodeFailTester { curator = new MockCurator(); nodeRepository = new NodeRepository(nodeFlavors, curator, clock, zone, new MockNameResolver().mockAnyLookup(), DockerImage.fromString("docker-registry.domain.tld:8080/dist/vespa"), true); - provisioner = new NodeRepositoryProvisioner(nodeRepository, nodeFlavors, zone, new MockProvisionServiceProvider(), new InMemoryFlagSource()); + provisioner = new NodeRepositoryProvisioner(nodeRepository, zone, new MockProvisionServiceProvider(), new InMemoryFlagSource()); hostLivenessTracker = new TestHostLivenessTracker(clock); orchestrator = new OrchestratorMock(); } diff --git a/node-repository/src/test/java/com/yahoo/vespa/hosted/provision/maintenance/OperatorChangeApplicationMaintainerTest.java b/node-repository/src/test/java/com/yahoo/vespa/hosted/provision/maintenance/OperatorChangeApplicationMaintainerTest.java index e1ac0430ee4..95f62521628 100644 --- a/node-repository/src/test/java/com/yahoo/vespa/hosted/provision/maintenance/OperatorChangeApplicationMaintainerTest.java +++ b/node-repository/src/test/java/com/yahoo/vespa/hosted/provision/maintenance/OperatorChangeApplicationMaintainerTest.java @@ -58,7 +58,7 @@ public class OperatorChangeApplicationMaintainerTest { new MockNameResolver().mockAnyLookup(), DockerImage.fromString("docker-registry.domain.tld:8080/dist/vespa"), true); - this.fixture = new Fixture(zone, nodeRepository, nodeFlavors); + this.fixture = new Fixture(zone, nodeRepository); createReadyNodes(15, this.fixture.nodeResources, nodeRepository); createHostNodes(2, nodeRepository, nodeFlavors); @@ -126,10 +126,12 @@ public class OperatorChangeApplicationMaintainerTest { final int wantedNodesApp1 = 5; final int wantedNodesApp2 = 7; - Fixture(Zone zone, NodeRepository nodeRepository, NodeFlavors flavors) { + Fixture(Zone zone, NodeRepository nodeRepository) { this.nodeRepository = nodeRepository; - NodeRepositoryProvisioner provisioner = new NodeRepositoryProvisioner( - nodeRepository, flavors, zone, new MockProvisionServiceProvider(), new InMemoryFlagSource()); + NodeRepositoryProvisioner provisioner = new NodeRepositoryProvisioner(nodeRepository, + zone, + new MockProvisionServiceProvider(), + new InMemoryFlagSource()); Map<ApplicationId, MockDeployer.ApplicationContext> apps = Map.of( app1, new MockDeployer.ApplicationContext(app1, clusterApp1, Capacity.fromCount(wantedNodesApp1, nodeResources), 1), diff --git a/node-repository/src/test/java/com/yahoo/vespa/hosted/provision/maintenance/PeriodicApplicationMaintainerTest.java b/node-repository/src/test/java/com/yahoo/vespa/hosted/provision/maintenance/PeriodicApplicationMaintainerTest.java index 211b4a4472f..94e43e4f99e 100644 --- a/node-repository/src/test/java/com/yahoo/vespa/hosted/provision/maintenance/PeriodicApplicationMaintainerTest.java +++ b/node-repository/src/test/java/com/yahoo/vespa/hosted/provision/maintenance/PeriodicApplicationMaintainerTest.java @@ -64,7 +64,7 @@ public class PeriodicApplicationMaintainerTest { new MockNameResolver().mockAnyLookup(), DockerImage.fromString("docker-registry.domain.tld:8080/dist/vespa"), true); - this.fixture = new Fixture(zone, nodeRepository, nodeFlavors); + this.fixture = new Fixture(zone, nodeRepository); createReadyNodes(15, fixture.nodeResources, nodeRepository); createHostNodes(2, nodeRepository, nodeFlavors); @@ -252,10 +252,12 @@ public class PeriodicApplicationMaintainerTest { private final TestablePeriodicApplicationMaintainer maintainer; - Fixture(Zone zone, NodeRepository nodeRepository, NodeFlavors flavors) { + Fixture(Zone zone, NodeRepository nodeRepository) { this.nodeRepository = nodeRepository; - NodeRepositoryProvisioner provisioner = new NodeRepositoryProvisioner( - nodeRepository, flavors, zone, new MockProvisionServiceProvider(), new InMemoryFlagSource()); + NodeRepositoryProvisioner provisioner = new NodeRepositoryProvisioner(nodeRepository, + zone, + new MockProvisionServiceProvider(), + new InMemoryFlagSource()); Map<ApplicationId, MockDeployer.ApplicationContext> apps = Map.of( app1, new MockDeployer.ApplicationContext(app1, clusterApp1, Capacity.fromCount(wantedNodesApp1, nodeResources), 1), diff --git a/node-repository/src/test/java/com/yahoo/vespa/hosted/provision/maintenance/ReservationExpirerTest.java b/node-repository/src/test/java/com/yahoo/vespa/hosted/provision/maintenance/ReservationExpirerTest.java index f8efb4fdea1..3861e4ff98c 100644 --- a/node-repository/src/test/java/com/yahoo/vespa/hosted/provision/maintenance/ReservationExpirerTest.java +++ b/node-repository/src/test/java/com/yahoo/vespa/hosted/provision/maintenance/ReservationExpirerTest.java @@ -48,7 +48,7 @@ public class ReservationExpirerTest { new MockNameResolver().mockAnyLookup(), DockerImage.fromString("docker-registry.domain.tld:8080/dist/vespa"), true); - NodeRepositoryProvisioner provisioner = new NodeRepositoryProvisioner(nodeRepository, flavors, Zone.defaultZone(), new MockProvisionServiceProvider(), new InMemoryFlagSource()); + NodeRepositoryProvisioner provisioner = new NodeRepositoryProvisioner(nodeRepository, Zone.defaultZone(), new MockProvisionServiceProvider(), new InMemoryFlagSource()); List<Node> nodes = new ArrayList<>(2); nodes.add(nodeRepository.createNode(UUID.randomUUID().toString(), UUID.randomUUID().toString(), Optional.empty(), new Flavor(new NodeResources(2, 8, 50)), NodeType.tenant)); diff --git a/node-repository/src/test/java/com/yahoo/vespa/hosted/provision/maintenance/RetiredExpirerTest.java b/node-repository/src/test/java/com/yahoo/vespa/hosted/provision/maintenance/RetiredExpirerTest.java index 5d3485ab447..7e471a81cf8 100644 --- a/node-repository/src/test/java/com/yahoo/vespa/hosted/provision/maintenance/RetiredExpirerTest.java +++ b/node-repository/src/test/java/com/yahoo/vespa/hosted/provision/maintenance/RetiredExpirerTest.java @@ -66,7 +66,7 @@ public class RetiredExpirerTest { private final NodeRepository nodeRepository = new NodeRepository(nodeFlavors, curator, clock, zone, new MockNameResolver().mockAnyLookup(), DockerImage.fromString("docker-registry.domain.tld:8080/dist/vespa"), true); - private final NodeRepositoryProvisioner provisioner = new NodeRepositoryProvisioner(nodeRepository, nodeFlavors, zone, new MockProvisionServiceProvider(), new InMemoryFlagSource()); + private final NodeRepositoryProvisioner provisioner = new NodeRepositoryProvisioner(nodeRepository, zone, new MockProvisionServiceProvider(), new InMemoryFlagSource()); private final Orchestrator orchestrator = mock(Orchestrator.class); private static final Duration RETIRED_EXPIRATION = Duration.ofHours(12); diff --git a/node-repository/src/test/java/com/yahoo/vespa/hosted/provision/provisioning/ProvisioningTester.java b/node-repository/src/test/java/com/yahoo/vespa/hosted/provision/provisioning/ProvisioningTester.java index 9f0b4faff01..8b1001c9c02 100644 --- a/node-repository/src/test/java/com/yahoo/vespa/hosted/provision/provisioning/ProvisioningTester.java +++ b/node-repository/src/test/java/com/yahoo/vespa/hosted/provision/provisioning/ProvisioningTester.java @@ -90,8 +90,8 @@ public class ProvisioningTester { DockerImage.fromString("docker-registry.domain.tld:8080/dist/vespa"), true); this.orchestrator = orchestrator; ProvisionServiceProvider provisionServiceProvider = new MockProvisionServiceProvider(loadBalancerService, hostProvisioner); - this.provisioner = new NodeRepositoryProvisioner(nodeRepository, nodeFlavors, zone, provisionServiceProvider, flagSource); - this.capacityPolicies = new CapacityPolicies(zone, nodeFlavors, new InMemoryFlagSource()); + this.provisioner = new NodeRepositoryProvisioner(nodeRepository, zone, provisionServiceProvider, flagSource); + this.capacityPolicies = new CapacityPolicies(zone, new InMemoryFlagSource()); this.provisionLogger = new NullProvisionLogger(); this.loadBalancerService = loadBalancerService; } |