diff options
author | Jon Marius Venstad <venstad@gmail.com> | 2020-11-06 18:11:37 +0100 |
---|---|---|
committer | Jon Marius Venstad <venstad@gmail.com> | 2020-11-06 18:11:37 +0100 |
commit | 7572c20d93c23756353aefbf4d12c3c214337220 (patch) | |
tree | 24b042bf197633f2d1b6685c4a06a1fae21636d3 /clustercontroller-reindexer/src/main/java/ai/vespa/reindexing/ReindexingMaintainer.java | |
parent | 604ddaefbb59f1353a16e25e45ad0c241cc79793 (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.java | 6 |
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); |