hadoop获取当前正在运作job数量的代码
// 我在这里只有一个Queue，名字叫做default，so，硬编码了。
Configuration conf = new Configuration();
conf.set("mapred.job.tracker", "YOUR_MAP_REDUCE_URL");
JobClient client;
try {
client = new JobClient(new JobConf(conf));
System.out.println(client.getQueues().getQueueName());
System.out.println(client.getJobsFromQueue(client.getQueues().getQueueName()).length);
} catch (IOException e) {
throw new RuntimeException(e);
}
-- end --
页:
[1]