diff options
author | HÃ¥kon Hallingstad <hakon.hallingstad@gmail.com> | 2023-11-27 10:55:05 +0100 |
---|---|---|
committer | GitHub <noreply@github.com> | 2023-11-27 10:55:05 +0100 |
commit | fbd789068d1fa8c0a726e85bb9f4efcb276e7523 (patch) | |
tree | 8a666d6de2bf670f934b1575f73662f05b92a64a /configserver-flags/src | |
parent | e090ce08f06345d04821a72ddc5fd7eca3a2fe4f (diff) | |
parent | 25bbeda88066a8041b336166086594ac07700adb (diff) |
Merge pull request #29471 from vespa-engine/jonmv/ZK-3.9.1
Shut down curator cache on shutdown
Diffstat (limited to 'configserver-flags/src')
-rw-r--r-- | configserver-flags/src/main/java/com/yahoo/vespa/configserver/flags/db/FlagsDbImpl.java | 9 |
1 files changed, 8 insertions, 1 deletions
diff --git a/configserver-flags/src/main/java/com/yahoo/vespa/configserver/flags/db/FlagsDbImpl.java b/configserver-flags/src/main/java/com/yahoo/vespa/configserver/flags/db/FlagsDbImpl.java index 09f5fcb7db9..f91dd2b9049 100644 --- a/configserver-flags/src/main/java/com/yahoo/vespa/configserver/flags/db/FlagsDbImpl.java +++ b/configserver-flags/src/main/java/com/yahoo/vespa/configserver/flags/db/FlagsDbImpl.java @@ -1,6 +1,7 @@ // Copyright Vespa.ai. Licensed under the terms of the Apache 2.0 license. See LICENSE in the project root. package com.yahoo.vespa.configserver.flags.db; +import com.yahoo.component.AbstractComponent; import com.yahoo.component.annotation.Inject; import com.yahoo.path.Path; import com.yahoo.vespa.configserver.flags.FlagsDb; @@ -20,7 +21,7 @@ import java.util.stream.Collectors; /** * @author hakonhall */ -public class FlagsDbImpl implements FlagsDb { +public class FlagsDbImpl extends AbstractComponent implements FlagsDb { private static final Path ROOT_PATH = Path.fromString("/flags/v1"); private final Curator curator; @@ -64,4 +65,10 @@ public class FlagsDbImpl implements FlagsDb { private static Path getZkPathFor(FlagId flagId) { return ROOT_PATH.append(flagId.toString()); } + + @Override + public void deconstruct() { + cache.close(); // Also shuts down the executor service + } + } |