1 files changed, 10 insertions, 0 deletions
diff --git a/clustercontroller-core/src/main/java/com/yahoo/vespa/clustercontroller/core/FleetController.java b/clustercontroller-core/src/main/java/com/yahoo/vespa/clustercontroller/core/FleetController.java
index 3e520d95d2c..3f7214c31e2 100644
--- a/clustercontroller-core/src/main/java/com/yahoo/vespa/clustercontroller/core/FleetController.java
+++ b/clustercontroller-core/src/main/java/com/yahoo/vespa/clustercontroller/core/FleetController.java
@@ -542,6 +542,7 @@ public class FleetController implements NodeListener, SlobrokListener, SystemSta
             didWork |= metricUpdater.forWork("processNextQueuedRemoteTask", this::processNextQueuedRemoteTask);
             didWork |= metricUpdater.forWork("completeSatisfiedVersionDependentTasks", this::completeSatisfiedVersionDependentTasks);
             didWork |= metricUpdater.forWork("maybePublishOldMetrics", this::maybePublishOldMetrics);
+            updateClusterSyncMetrics();
 
             processingCycle = false;
             ++cycleCount;
@@ -563,6 +564,14 @@ public class FleetController implements NodeListener, SlobrokListener, SystemSta
         }
     }
 
+    private void updateClusterSyncMetrics() {
+        var stats = stateVersionTracker.getAggregatedClusterStats().getAggregatedStats();
+        if (stats.hasUpdatesFromAllDistributors()) {
+            GlobalBucketSyncStatsCalculator.clusterBucketsOutOfSyncRatio(stats.getGlobalStats())
+                    .ifPresent(metricUpdater::updateClusterBucketsOutOfSyncRatio);
+        }
+    }
+
     private boolean updateMasterElectionState() {
         try {
             return masterElectionHandler.watchMasterElection(database, databaseContext);
@@ -689,6 +698,7 @@ public class FleetController implements NodeListener, SlobrokListener, SystemSta
         context.cluster = cluster;
         context.currentConsolidatedState = consolidatedClusterState();
         context.publishedClusterStateBundle = stateVersionTracker.getVersionedClusterStateBundle();
+        context.aggregatedClusterStats = stateVersionTracker.getAggregatedClusterStats().getAggregatedStats();
         context.masterInfo = new MasterInterface() {
             @Override public boolean isMaster() { return isMaster; }
             @Override public Integer getMaster() { return masterElectionHandler.getMaster(); }