diff options
author | Harald Musum <musum@verizonmedia.com> | 2019-11-08 13:33:17 +0100 |
---|---|---|
committer | GitHub <noreply@github.com> | 2019-11-08 13:33:17 +0100 |
commit | 642956eb20b5a79f9781bdb77033c8a13f738701 (patch) | |
tree | 98c2db2b9fcda5a11370a083f84dd5be69197c86 /node-repository | |
parent | 6de289eee885ecd31315505f0134f5da00d13aaf (diff) | |
parent | e2c190fa4f3549f969c47086177d7441e292f8f5 (diff) |
Merge pull request #11251 from vespa-engine/hmusum/log-parent-hosts-not-ready
Log parent hosts that are not ready
Diffstat (limited to 'node-repository')
-rw-r--r-- | node-repository/src/main/java/com/yahoo/vespa/hosted/provision/provisioning/Activator.java | 13 |
1 files changed, 10 insertions, 3 deletions
diff --git a/node-repository/src/main/java/com/yahoo/vespa/hosted/provision/provisioning/Activator.java b/node-repository/src/main/java/com/yahoo/vespa/hosted/provision/provisioning/Activator.java index e994e86d07c..11df1aa8c35 100644 --- a/node-repository/src/main/java/com/yahoo/vespa/hosted/provision/provisioning/Activator.java +++ b/node-repository/src/main/java/com/yahoo/vespa/hosted/provision/provisioning/Activator.java @@ -6,6 +6,7 @@ import com.yahoo.config.provision.ClusterMembership; import com.yahoo.config.provision.ClusterSpec; import com.yahoo.config.provision.HostSpec; import com.yahoo.config.provision.ParentHostUnavailableException; +import com.yahoo.log.LogLevel; import com.yahoo.transaction.Mutex; import com.yahoo.transaction.NestedTransaction; import com.yahoo.vespa.hosted.provision.Node; @@ -19,6 +20,7 @@ import java.util.HashSet; import java.util.List; import java.util.Optional; import java.util.Set; +import java.util.logging.Logger; import java.util.stream.Collectors; /** @@ -28,6 +30,8 @@ import java.util.stream.Collectors; */ class Activator { + private static final Logger logger = Logger.getLogger(Activator.class.getName()); + private final NodeRepository nodeRepository; private final Optional<LoadBalancerProvisioner> loadBalancerProvisioner; @@ -108,12 +112,15 @@ class Activator { .flatMap(Optional::stream) .collect(Collectors.toSet()); - long numNonActive = nodes.asList().stream() + Set<String> nonActiveHosts = nodes.asList().stream() .filter(node -> parentHostnames.contains(node.hostname())) .filter(node -> node.state() != Node.State.active) - .count(); - + .map(Node::hostname) + .collect(Collectors.toSet()); + long numNonActive = nonActiveHosts.size(); if (numNonActive > 0) { + // Note: log parent hosts not ready, but do not add to exception (to avoid leaking hostnames) + logger.log(LogLevel.INFO, application + ": Parent hosts not ready: " + nonActiveHosts); throw new ParentHostUnavailableException("Waiting for hosts to finish booting: " + numNonActive + "/" + parentHostnames.size() + " left."); } |