|
@@ -491,6 +491,7 @@ public class BlockManager implements BlockStatsMXBean {
|
|
public void activate(Configuration conf) {
|
|
public void activate(Configuration conf) {
|
|
pendingReplications.start();
|
|
pendingReplications.start();
|
|
datanodeManager.activate(conf);
|
|
datanodeManager.activate(conf);
|
|
|
|
+ this.replicationThread.setName("ReplicationMonitor");
|
|
this.replicationThread.start();
|
|
this.replicationThread.start();
|
|
mxBeanName = MBeans.register("NameNode", "BlockStats", this);
|
|
mxBeanName = MBeans.register("NameNode", "BlockStats", this);
|
|
}
|
|
}
|