如何得到不.在mapreduce程序中使用java实现对HADOOP集群中活节点的映射

Question

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

hadoop dfsadmin --report

我们已经试过这个代码....

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

在Java mapreduce程序如何获得没有活节点?

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();

如果你想获得的不仅仅是活动节点，你可以在client.getNodeReports()方法中更改或添加更多的节点状态。