diff options
author | Harald Musum <musum@verizonmedia.com> | 2020-10-02 14:03:09 +0200 |
---|---|---|
committer | Harald Musum <musum@verizonmedia.com> | 2020-10-02 14:03:09 +0200 |
commit | 2972dba202ac5a060f4ed30676f5594f10632042 (patch) | |
tree | a7e42e02b616d3696a182e0453708a85f1d2b005 | |
parent | 183f2cd98d89863091d07c4402ed1e4e3b8a2105 (diff) |
Go back to creating waiter before prepare
-rw-r--r-- | configserver/src/main/java/com/yahoo/vespa/config/server/session/SessionRepository.java | 3 |
1 files changed, 2 insertions, 1 deletions
diff --git a/configserver/src/main/java/com/yahoo/vespa/config/server/session/SessionRepository.java b/configserver/src/main/java/com/yahoo/vespa/config/server/session/SessionRepository.java index 53230eec831..edc7a070063 100644 --- a/configserver/src/main/java/com/yahoo/vespa/config/server/session/SessionRepository.java +++ b/configserver/src/main/java/com/yahoo/vespa/config/server/session/SessionRepository.java @@ -159,6 +159,7 @@ public class SessionRepository { logger.log(Level.FINE, "Created application " + params.getApplicationId()); long sessionId = session.getSessionId(); SessionZooKeeperClient sessionZooKeeperClient = createSessionZooKeeperClient(sessionId); + Curator.CompletionWaiter waiter = sessionZooKeeperClient.createPrepareWaiter(); Optional<ApplicationSet> activeApplicationSet = getActiveApplicationSet(params.getApplicationId()); ConfigChangeActions actions = sessionPreparer.prepare(applicationRepo.getHostValidator(), logger, params, activeApplicationSet, tenantPath, now, @@ -166,7 +167,7 @@ public class SessionRepository { session.getApplicationPackage(), sessionZooKeeperClient) .getConfigChangeActions(); setPrepared(session); - sessionZooKeeperClient.createPrepareWaiter().awaitCompletion(params.getTimeoutBudget().timeLeft()); + waiter.awaitCompletion(params.getTimeoutBudget().timeLeft()); return actions; } |