summaryrefslogtreecommitdiffstats
path: root/clustercontroller-apps
diff options
context:
space:
mode:
authorJon Marius Venstad <venstad@gmail.com>2021-02-19 11:42:30 +0100
committerJon Marius Venstad <venstad@gmail.com>2021-02-19 11:42:30 +0100
commit57246e2533f993b0a877ff1f09a5824f272c9550 (patch)
treec343da8d6f952b3d1d72edab20cfef76764d2076 /clustercontroller-apps
parentd17f332e2d7cf3ef46d2631a95ced792277c1242 (diff)
Die after 1 minute if no ZK-connection when constructing CC
Diffstat (limited to 'clustercontroller-apps')
-rw-r--r--clustercontroller-apps/src/main/java/com/yahoo/vespa/clustercontroller/apps/clustercontroller/ClusterController.java4
1 files changed, 3 insertions, 1 deletions
diff --git a/clustercontroller-apps/src/main/java/com/yahoo/vespa/clustercontroller/apps/clustercontroller/ClusterController.java b/clustercontroller-apps/src/main/java/com/yahoo/vespa/clustercontroller/apps/clustercontroller/ClusterController.java
index df0e7b7d0b5..bd105c5c6c1 100644
--- a/clustercontroller-apps/src/main/java/com/yahoo/vespa/clustercontroller/apps/clustercontroller/ClusterController.java
+++ b/clustercontroller-apps/src/main/java/com/yahoo/vespa/clustercontroller/apps/clustercontroller/ClusterController.java
@@ -16,6 +16,7 @@ import com.yahoo.vespa.zookeeper.VespaZooKeeperServer;
import java.util.LinkedHashMap;
import java.util.Map;
import java.util.TreeMap;
+import java.util.concurrent.TimeUnit;
import java.util.logging.Logger;
/**
@@ -98,7 +99,8 @@ public class ClusterController extends AbstractComponent
private void verifyThatZooKeeperWorks(FleetControllerOptions options) throws Exception {
if (options.zooKeeperServerAddress != null && !"".equals(options.zooKeeperServerAddress)) {
try (Curator curator = Curator.create(options.zooKeeperServerAddress)) {
- curator.framework().blockUntilConnected();
+ if ( ! curator.framework().blockUntilConnected(60, TimeUnit.SECONDS))
+ com.yahoo.protect.Process.logAndDie("Failed to connect to ZK, dying and restarting container");
}
}
}