private void setClusterLevelDaemons(YarnMaster master,
ClusterWideInfo clusterWideInfo,
ProfilerJMXDump dump)
throws IOException, AttributeNotFoundException,
InstanceNotFoundException, MBeanException, ReflectionException,
IntrospectionException {
clusterWideInfo.setNameNode(dump.getAllJMXAttribute(
JMXDeamons.NAME_NODE ,master.getHost(),
master.getNameNodeJmxPort()));
if (isYarnEnable) {
YarnClusterWideInfo yarnClusterWideInfo = (YarnClusterWideInfo) clusterWideInfo;
yarnClusterWideInfo.setResourceManager(dump.getAllJMXAttribute(
JMXDeamons.RESOURCE_MANAGER,
master.getHost(), master.getResourceManagerJmxPort()));
} else {
clusterWideInfo.setJobTracker(dump.getAllJMXAttribute(
JMXDeamons.JOB_TRACKER, master.getHost(),
master.getJobTrackerJmxPort()));
}
}
ExecutionServlet.java 文件源码
java
阅读 21
收藏 0
点赞 0
评论 0
项目:jumbune
作者:
评论列表
文章目录