aboutsummaryrefslogtreecommitdiffstats
path: root/configserver
diff options
context:
space:
mode:
authorHarald Musum <musum@oath.com>2017-11-19 08:07:22 +0100
committerHarald Musum <musum@oath.com>2017-11-19 08:07:22 +0100
commit7692b4adc7028bd7c57cd185deb8af3877924e60 (patch)
tree1f88d66a311f63964d25fb05f9834ca43c5c3be4 /configserver
parent33b2792d14e80e9bdab47b4186d1ba32ffa27c5e (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.java8
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);
}