diff --git a/hadoop-hdds/server-scm/src/main/java/org/apache/hadoop/hdds/scm/container/replication/ReplicationManager.java b/hadoop-hdds/server-scm/src/main/java/org/apache/hadoop/hdds/scm/container/replication/ReplicationManager.java index d1d8a3782bf..4974407f363 100644 --- a/hadoop-hdds/server-scm/src/main/java/org/apache/hadoop/hdds/scm/container/replication/ReplicationManager.java +++ b/hadoop-hdds/server-scm/src/main/java/org/apache/hadoop/hdds/scm/container/replication/ReplicationManager.java @@ -243,6 +243,7 @@ public ReplicationManager(final ConfigurationSource conf, this.ratisReplicationCheckHandler = new RatisReplicationCheckHandler(ratisContainerPlacement); this.nodeManager = nodeManager; + this.metrics = ReplicationManagerMetrics.create(this); ecUnderReplicationHandler = new ECUnderReplicationHandler( ecContainerPlacement, conf, this); @@ -285,7 +286,6 @@ public synchronized void start() { if (!isRunning()) { LOG.info("Starting Replication Monitor Thread."); running = true; - metrics = ReplicationManagerMetrics.create(this); if (rmConf.isLegacyEnabled()) { legacyReplicationManager.setMetrics(metrics); }