Keep metrics in sync across cluster controller containers

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()));