aboutsummaryrefslogtreecommitdiffstats
path: root/clustercontroller-reindexer/src/main/java/ai/vespa/reindexing/ReindexingMaintainer.java
diff options
context:
space:
mode:
authorJon Marius Venstad <venstad@gmail.com>2020-11-06 18:11:37 +0100
committerJon Marius Venstad <venstad@gmail.com>2020-11-06 18:11:37 +0100
commit7572c20d93c23756353aefbf4d12c3c214337220 (patch)
tree24b042bf197633f2d1b6685c4a06a1fae21636d3 /clustercontroller-reindexer/src/main/java/ai/vespa/reindexing/ReindexingMaintainer.java
parent604ddaefbb59f1353a16e25e45ad0c241cc79793 (diff)
Address review comments, and fix unit test
Diffstat (limited to 'clustercontroller-reindexer/src/main/java/ai/vespa/reindexing/ReindexingMaintainer.java')
-rw-r--r--clustercontroller-reindexer/src/main/java/ai/vespa/reindexing/ReindexingMaintainer.java6
1 files changed, 3 insertions, 3 deletions
diff --git a/clustercontroller-reindexer/src/main/java/ai/vespa/reindexing/ReindexingMaintainer.java b/clustercontroller-reindexer/src/main/java/ai/vespa/reindexing/ReindexingMaintainer.java
index 054a91458d7..0addf12b4c1 100644
--- a/clustercontroller-reindexer/src/main/java/ai/vespa/reindexing/ReindexingMaintainer.java
+++ b/clustercontroller-reindexer/src/main/java/ai/vespa/reindexing/ReindexingMaintainer.java
@@ -27,17 +27,17 @@ import java.util.concurrent.ScheduledExecutorService;
import java.util.concurrent.ScheduledThreadPoolExecutor;
import java.util.concurrent.TimeUnit;
import java.util.function.BiConsumer;
-import java.util.logging.Level;
import java.util.logging.Logger;
import java.util.stream.Stream;
+import static java.util.logging.Level.FINE;
import static java.util.logging.Level.WARNING;
import static java.util.stream.Collectors.toList;
import static java.util.stream.Collectors.toMap;
import static java.util.stream.Collectors.toUnmodifiableMap;
/**
- * Runs in all cluster controller containers, and progresses reindexngg efforts.
+ * Runs in all cluster controller containers, and progresses reindexing efforts.
* Work is only done by one container at a time, by requiring a shared ZooKeeper lock to be held while visiting.
* Whichever maintainer gets the lock holds it until all reindexing is done, or until shutdown.
*
@@ -78,7 +78,7 @@ public class ReindexingMaintainer extends AbstractComponent {
reindexer.reindex();
}
catch (ReindexingLockException e) {
- // Some other container is handling the reindexing at this moment, which is fine.
+ log.log(FINE, "Failed to acquire reindexing lock");
}
catch (Exception e) {
log.log(WARNING, "Exception when reindexing", e);