diff options
author | Harald Musum <musum@oath.com> | 2017-11-19 08:07:22 +0100 |
---|---|---|
committer | Harald Musum <musum@oath.com> | 2017-11-19 08:07:22 +0100 |
commit | 7692b4adc7028bd7c57cd185deb8af3877924e60 (patch) | |
tree | 1f88d66a311f63964d25fb05f9834ca43c5c3be4 /configserver | |
parent | 33b2792d14e80e9bdab47b4186d1ba32ffa27c5e (diff) |
Use scheduleWithFixedDelay and log at debug level
Diffstat (limited to 'configserver')
-rw-r--r-- | configserver/src/main/java/com/yahoo/vespa/config/server/application/ZKTenantApplications.java | 8 |
1 files changed, 5 insertions, 3 deletions
diff --git a/configserver/src/main/java/com/yahoo/vespa/config/server/application/ZKTenantApplications.java b/configserver/src/main/java/com/yahoo/vespa/config/server/application/ZKTenantApplications.java index bb482d71374..c3d13b86591 100644 --- a/configserver/src/main/java/com/yahoo/vespa/config/server/application/ZKTenantApplications.java +++ b/configserver/src/main/java/com/yahoo/vespa/config/server/application/ZKTenantApplications.java @@ -60,8 +60,10 @@ public class ZKTenantApplications implements TenantApplications, PathChildrenCac this.directoryCache = curator.createDirectoryCache(applicationsPath.getAbsolute(), false, false, pathChildrenExecutor); this.directoryCache.start(); this.directoryCache.addListener(this); - checkForRemovedApplicationsService.scheduleAtFixedRate(this::removeApplications, checkForRemovedApplicationsInterval.getSeconds(), - checkForRemovedApplicationsInterval.getSeconds(), TimeUnit.SECONDS); + checkForRemovedApplicationsService.scheduleWithFixedDelay(this::removeApplications, + checkForRemovedApplicationsInterval.getSeconds(), + checkForRemovedApplicationsInterval.getSeconds(), + TimeUnit.SECONDS); } public static TenantApplications create(Curator curator, ReloadHandler reloadHandler, TenantName tenant) { @@ -163,7 +165,7 @@ public class ZKTenantApplications implements TenantApplications, PathChildrenCac private void removeApplications() { ImmutableSet<ApplicationId> activeApplications = ImmutableSet.copyOf(listApplications()); - log.log(LogLevel.INFO, "Removing stale applications for tenant '" + tenant + + log.log(LogLevel.DEBUG, "Removing stale applications for tenant '" + tenant + "', not removing these active applications: " + activeApplications); reloadHandler.removeApplicationsExcept(activeApplications); } |