aboutsummaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authorValerij Fredriksen <valerijf@yahooinc.com>2023-05-12 15:05:01 +0200
committerValerij Fredriksen <valerijf@yahooinc.com>2023-05-12 15:12:19 +0200
commit496ba384a076c6e3353639c7d28ca756257d011e (patch)
treec2969abf7d454f88a5f4ab11f4134ea7e4103a06
parentf2334d2df98f96eb66bf097a1c4bbc0f89ef4b3e (diff)
Do not count already retired nodes as retired just now
-rw-r--r--node-repository/src/main/java/com/yahoo/vespa/hosted/provision/provisioning/NodeAllocation.java2
-rw-r--r--node-repository/src/test/java/com/yahoo/vespa/hosted/provision/provisioning/ProvisioningTest.java30
2 files changed, 30 insertions, 2 deletions
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 484c5abdb89..f3f4e85f4b2 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
@@ -268,7 +268,7 @@ class NodeAllocation {
if (node.state() != Node.State.active) // reactivated node - wipe state that deactivated it
node = node.unretire().removable(false);
- } else {
+ } else if (retirement != Retirement.alreadyRetired) {
LOG.info("Retiring " + node + " because " + retirement.description());
++wasRetiredJustNow;
node = node.retire(nodeRepository.clock().instant());
diff --git a/node-repository/src/test/java/com/yahoo/vespa/hosted/provision/provisioning/ProvisioningTest.java b/node-repository/src/test/java/com/yahoo/vespa/hosted/provision/provisioning/ProvisioningTest.java
index 2cd0e84c356..28cd3067155 100644
--- a/node-repository/src/test/java/com/yahoo/vespa/hosted/provision/provisioning/ProvisioningTest.java
+++ b/node-repository/src/test/java/com/yahoo/vespa/hosted/provision/provisioning/ProvisioningTest.java
@@ -770,7 +770,35 @@ public class ProvisioningTest {
tester.patchNodes(nodes.asList(), node -> node.withWantToRetire(true, Agent.system, tester.clock().instant()));
tester.activate(application, tester.prepare(application, cluster, 3, 1, defaultResources));
- assertEquals(3, tester.getNodes(application).state(Node.State.active).not().retired().size());
+ assertEquals(3, tester.getNodes(application).state(Node.State.active).size());
+ }
+
+ @Test
+ public void fails_if_retired_and_no_capacity() {
+ ProvisioningTester tester = new ProvisioningTester.Builder().zone(new Zone(Environment.prod, RegionName.from("us-east"))).build();
+ tester.makeReadyHosts(4, defaultResources).activateTenantHosts();
+
+ ApplicationId application = ProvisioningTester.applicationId();
+ ClusterSpec cluster = ClusterSpec.request(ClusterSpec.Type.content, ClusterSpec.Id.from("music")).vespaVersion("4.5.6").build();
+ tester.activate(application, tester.prepare(application, cluster, 3, 1, defaultResources));
+
+ // Retire one node
+ tester.patchNodes(tester.getNodes(application).first(1).asList(),
+ node -> node.withWantToRetire(true, Agent.system, tester.clock().instant()));
+
+ tester.activate(application, tester.prepare(application, cluster, 3, 1, defaultResources));
+ assertEquals(4, tester.getNodes(application).state(Node.State.active).size());
+
+ // Retire another node
+ tester.patchNodes(tester.getNodes(application).not().retired().first(1).asList(),
+ node -> node.withWantToRetire(true, Agent.system, tester.clock().instant()));
+
+ try {
+ // Deploy with increased cluster size, at this point there is no capacity even if we deploy
+ // without considering retirements
+ tester.activate(application, tester.prepare(application, cluster, 5, 1, defaultResources));
+ fail("Expected to failed due to lack of capacity");
+ } catch (NodeAllocationException ignored) {}
}
@Test