aboutsummaryrefslogtreecommitdiffstats
path: root/clustercontroller-reindexer
diff options
context:
space:
mode:
authorHenning Baldersheim <balder@yahoo-inc.com>2022-01-31 11:32:19 +0100
committerHenning Baldersheim <balder@yahoo-inc.com>2022-01-31 11:32:19 +0100
commit7a4168c1d244c87675cdb6d6453ccca449de021b (patch)
treee637ca00d9c193173d38600e177c257561f89422 /clustercontroller-reindexer
parentf2004be273f31ee02f7038b1a959a3e77fc4e4b9 (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.java3
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());