java - 如何获得编号使用java的mapreduce程序中HADOOP集群中的 Activity 节点

Question

在终端中，它将使用以下命令显示没有 Activity 节点:

hadoop dfsadmin --report

我们已经尝试过这段代码....

FSNamesystem fs=FSNamesystem.getFSNamesystem();
String s=fs.getFSState();
System.out.println(s+"\n\n");

在java mapreduce程序中如何获取 Activity 节点数？

Answer 1

在 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() 方法中更改或添加更多节点状态。