diff options
| author | Jon Marius Venstad <jonmv@users.noreply.github.com> | 2020-12-09 14:55:54 +0100 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2020-12-09 14:55:54 +0100 |
| commit | b3a1ba0cd48bdad64d672a03ad69551fad942670 (patch) | |
| tree | 94cd40fed0c872436ea916e73a79ce77d26a6afe /clustercontroller-reindexer | |
| parent | 82c41ca9a1ebe439e4498734a974dc362764ba89 (diff) | |
| parent | 40197fe61f0b044f963f9f37298b1760d12e3ec0 (diff) | |
Merge pull request #15758 from vespa-engine/jonmv/reindexing-metrics-every-minute-on-all-containers
Keep metrics in sync across cluster controller containers
Diffstat (limited to 'clustercontroller-reindexer')
| -rw-r--r-- | clustercontroller-reindexer/src/main/java/ai/vespa/reindexing/Reindexer.java | 3 |
1 files changed, 3 insertions, 0 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 19dfd031dfc..c0a54d55a03 100644 --- a/clustercontroller-reindexer/src/main/java/ai/vespa/reindexing/Reindexer.java +++ b/clustercontroller-reindexer/src/main/java/ai/vespa/reindexing/Reindexer.java @@ -91,6 +91,9 @@ public class Reindexer { if (phaser.isTerminated()) throw new IllegalStateException("Already shut down"); + // Keep metrics in sync across cluster controller containers. + metrics.dump(database.readReindexing(cluster.name)); + try (Lock lock = database.lockReindexing(cluster.name())) { AtomicReference<Reindexing> reindexing = new AtomicReference<>(database.readReindexing(cluster.name())); reindexing.set(updateWithReady(ready, reindexing.get(), clock.instant())); |