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()[0].getQueueName());System.out.println(client.getJobsFromQueue(client.getQueues()[0].getQueueName()).length);} catch (IOException e) {throw new RuntimeException(e);}

-- end --

?

?