|
@@ -365,7 +365,7 @@ public class DataNode extends Configured
|
|
|
this.infoServer.start();
|
|
|
// adjust info port
|
|
|
this.dnRegistration.setInfoPort(this.infoServer.getPort());
|
|
|
- myMetrics = new DataNodeMetrics(conf, dnRegistration.getStorageID());
|
|
|
+ myMetrics = new DataNodeMetrics(conf, dnRegistration.getName());
|
|
|
|
|
|
//init ipc server
|
|
|
InetSocketAddress ipcAddr = NetUtils.createSocketAddr(
|