在终端中,它将使用以下命令显示没有 Activity 节点:
hadoop dfsadmin --report
我们已经尝试过这段代码....
FSNamesystem fs=FSNamesystem.getFSNamesystem();
String s=fs.getFSState();
System.out.println(s+"\n\n");
在java mapreduce程序中如何获取 Activity 节点数?
最佳答案
在 MapReduce 作业中,您可以使用以下代码:
YarnClient client = YarnClient.createYarnClient();
Configuration config = context.getConfiguration();
client.init(new YarnConfiguration(config));
client.start();
try {
List<NodeReport> reports = client.getNodeReports(NodeState.RUNNING);
System.out.println(reports.size());
}
catch (Exception ex) {
System.err.println(ex.getMessage());
}
client.stop();
如果您不仅想要获取 Activity 节点,还可以在 client.getNodeReports()
方法中更改或添加更多节点状态。
关于java - 如何获得编号使用java的mapreduce程序中HADOOP集群中的 Activity 节点,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/32881261/