big-data/hadoop
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

HDFS-11003. Expose XmitsInProgress through DataNodeMXBean. Contributed By Brahma Reddy Battula

Browse Source
This commit is contained in:
Brahma Reddy Battula 2016-10-15 22:28:33 +05:30
parent 5ad037df25
commit 5f4ae85bd8
3 changed files with 14 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/datanode/DataNode.java
View File

@ -2101,8 +2101,9 @@ public class DataNode extends ReconfigurableBase
} }
} }
} }
int getXmitsInProgress() { @Override //DataNodeMXBean
public int getXmitsInProgress() {
return xmitsInProgress.get(); return xmitsInProgress.get();
} }

6
hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/datanode/DataNodeMXBean.java
View File

@ -100,6 +100,12 @@ public interface DataNodeMXBean {
*/ */
public int getXceiverCount(); public int getXceiverCount();
/**
* Returns an estimate of the number of data replication/reconstruction tasks
* running currently.
*/
public int getXmitsInProgress();
/** /**
* Gets the network error counts on a per-Datanode basis. * Gets the network error counts on a per-Datanode basis.
*/ */

6
hadoop-hdfs-project/hadoop-hdfs/src/test/java/org/apache/hadoop/hdfs/server/datanode/TestDataNodeMXBean.java
View File

@ -96,7 +96,11 @@ public class TestDataNodeMXBean {
int xceiverCount = (Integer)mbs.getAttribute(mxbeanName, int xceiverCount = (Integer)mbs.getAttribute(mxbeanName,
"XceiverCount"); "XceiverCount");
Assert.assertEquals(datanode.getXceiverCount(), xceiverCount); Assert.assertEquals(datanode.getXceiverCount(), xceiverCount);
// Ensure mxbean's XmitsInProgress is same as the DataNode's
// live value.
int xmitsInProgress =
(Integer) mbs.getAttribute(mxbeanName, "XmitsInProgress");
Assert.assertEquals(datanode.getXmitsInProgress(), xmitsInProgress);
String bpActorInfo = (String)mbs.getAttribute(mxbeanName, String bpActorInfo = (String)mbs.getAttribute(mxbeanName,
"BPServiceActorInfo"); "BPServiceActorInfo");
Assert.assertEquals(datanode.getBPServiceActorInfo(), bpActorInfo); Assert.assertEquals(datanode.getBPServiceActorInfo(), bpActorInfo);