|
@@ -103,10 +103,12 @@ public class TestJMXGet {
|
|
assertTrue("error printAllValues", checkPrintAllValues(jmx));
|
|
assertTrue("error printAllValues", checkPrintAllValues(jmx));
|
|
|
|
|
|
//get some data from different source
|
|
//get some data from different source
|
|
|
|
+ DFSTestUtil.waitForMetric(jmx, "NumLiveDataNodes", numDatanodes);
|
|
assertEquals(numDatanodes, Integer.parseInt(
|
|
assertEquals(numDatanodes, Integer.parseInt(
|
|
jmx.getValue("NumLiveDataNodes")));
|
|
jmx.getValue("NumLiveDataNodes")));
|
|
assertGauge("CorruptBlocks", Long.parseLong(jmx.getValue("CorruptBlocks")),
|
|
assertGauge("CorruptBlocks", Long.parseLong(jmx.getValue("CorruptBlocks")),
|
|
getMetrics("FSNamesystem"));
|
|
getMetrics("FSNamesystem"));
|
|
|
|
+ DFSTestUtil.waitForMetric(jmx, "NumOpenConnections", numDatanodes);
|
|
assertEquals(numDatanodes, Integer.parseInt(
|
|
assertEquals(numDatanodes, Integer.parseInt(
|
|
jmx.getValue("NumOpenConnections")));
|
|
jmx.getValue("NumOpenConnections")));
|
|
|
|
|
|
@@ -151,6 +153,7 @@ public class TestJMXGet {
|
|
String serviceName = "DataNode";
|
|
String serviceName = "DataNode";
|
|
jmx.setService(serviceName);
|
|
jmx.setService(serviceName);
|
|
jmx.init();
|
|
jmx.init();
|
|
|
|
+ DFSTestUtil.waitForMetric(jmx, "BytesWritten", fileSize);
|
|
assertEquals(fileSize, Integer.parseInt(jmx.getValue("BytesWritten")));
|
|
assertEquals(fileSize, Integer.parseInt(jmx.getValue("BytesWritten")));
|
|
|
|
|
|
cluster.shutdown();
|
|
cluster.shutdown();
|