diff options
author | Henning Baldersheim <balder@yahoo-inc.com> | 2022-01-31 11:32:19 +0100 |
---|---|---|
committer | Henning Baldersheim <balder@yahoo-inc.com> | 2022-01-31 11:32:19 +0100 |
commit | 7a4168c1d244c87675cdb6d6453ccca449de021b (patch) | |
tree | e637ca00d9c193173d38600e177c257561f89422 /clustercontroller-reindexer | |
parent | f2004be273f31ee02f7038b1a959a3e77fc4e4b9 (diff) |
Increase interval to store progress token from 10s to 60s
Diffstat (limited to 'clustercontroller-reindexer')
-rw-r--r-- | clustercontroller-reindexer/src/main/java/ai/vespa/reindexing/Reindexer.java | 3 |
1 files changed, 2 insertions, 1 deletions
diff --git a/clustercontroller-reindexer/src/main/java/ai/vespa/reindexing/Reindexer.java b/clustercontroller-reindexer/src/main/java/ai/vespa/reindexing/Reindexer.java index 4fe7ee74d6d..8cebc091772 100644 --- a/clustercontroller-reindexer/src/main/java/ai/vespa/reindexing/Reindexer.java +++ b/clustercontroller-reindexer/src/main/java/ai/vespa/reindexing/Reindexer.java @@ -46,6 +46,7 @@ public class Reindexer { private static final Logger log = Logger.getLogger(Reindexer.class.getName()); static final Duration failureGrace = Duration.ofMinutes(10); + static final Duration PROGRESS_TOKEN_STORE_INTERVAL = Duration.ofSeconds(60); private final Cluster cluster; private final List<Trigger> ready; @@ -160,7 +161,7 @@ public class Reindexer { public void onProgress(ProgressToken token) { super.onProgress(token); status.updateAndGet(value -> value.progressed(token)); - if (progressLastStored.get().isBefore(clock.instant().minusSeconds(10))) { + if (progressLastStored.get().isBefore(clock.instant().minus(PROGRESS_TOKEN_STORE_INTERVAL))) { progressLastStored.set(clock.instant()); database.writeReindexing(reindexing.updateAndGet(value -> value.with(type, status.get())), cluster.name()); metrics.dump(reindexing.get()); |