aboutsummaryrefslogtreecommitdiffstats
path: root/node-repository
diff options
context:
space:
mode:
authorHarald Musum <musum@verizonmedia.com>2022-11-23 10:13:27 +0100
committerGitHub <noreply@github.com>2022-11-23 10:13:27 +0100
commite03f1e82952dbdb801e737de41b285c0fa74c3f9 (patch)
treebc443af370c668022b3ff8035cf0ba7af10c234d /node-repository
parent8ccd836e176f4d1bea05ee835428977c50463e0e (diff)
parent3aceb3983776e89f911072a2b5e4e927adb2f5bf (diff)
Merge pull request #24962 from vespa-engine/hakonhall/log-when-retiredexpirer-is-unsuccessful
Log when RetiredExpirer is unsuccessful
Diffstat (limited to 'node-repository')
-rw-r--r--node-repository/src/main/java/com/yahoo/vespa/hosted/provision/maintenance/RetiredExpirer.java16
1 files changed, 12 insertions, 4 deletions
diff --git a/node-repository/src/main/java/com/yahoo/vespa/hosted/provision/maintenance/RetiredExpirer.java b/node-repository/src/main/java/com/yahoo/vespa/hosted/provision/maintenance/RetiredExpirer.java
index 3143fb5bcfe..87af8c05b14 100644
--- a/node-repository/src/main/java/com/yahoo/vespa/hosted/provision/maintenance/RetiredExpirer.java
+++ b/node-repository/src/main/java/com/yahoo/vespa/hosted/provision/maintenance/RetiredExpirer.java
@@ -15,6 +15,8 @@ import com.yahoo.yolean.Exceptions;
import java.time.Duration;
import java.util.Map;
+import java.util.Optional;
+import java.util.OptionalLong;
/**
* Maintenance job which deactivates retired nodes, if given permission by orchestrator, or
@@ -61,13 +63,19 @@ public class RetiredExpirer extends NodeRepositoryMaintainer {
NodeList nodes = kv.getValue();
attempts++;
try (MaintenanceDeployment deployment = new MaintenanceDeployment(application, deployer, metric, nodeRepository())) {
- if (!deployment.isValid()) continue;
+ if (!deployment.isValid()) {
+ log.info("Skipping invalid deployment for " + application);
+ continue;
+ }
nodeRepository().nodes().setRemovable(application, nodes.asList(), removal.isReusable());
- boolean success = deployment.activate().isPresent();
- if (!success) continue;
+ Optional<Long> session = deployment.activate();
String nodeList = String.join(", ", nodes.mapToList(Node::hostname));
- log.info("Redeployed " + application + " to deactivate retired nodes: " + nodeList);
+ if (session.isEmpty()) {
+ log.info("Failed to redeploy " + application);
+ continue;
+ }
+ log.info("Redeployed " + application + " at session " + session.get() + " to deactivate retired nodes: " + nodeList);
successes++;
}
}