diff options
author | Jon Marius Venstad <venstad@gmail.com> | 2020-12-09 14:52:04 +0100 |
---|---|---|
committer | Jon Marius Venstad <venstad@gmail.com> | 2020-12-09 14:52:04 +0100 |
commit | 40197fe61f0b044f963f9f37298b1760d12e3ec0 (patch) | |
tree | 849be7d34aefe70528dbc579eb1d20879f9f44d6 /clustercontroller-reindexer | |
parent | 25cbf4637a2f312f7646ec1c47916368a747d983 (diff) |
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())); |