hadoop - Hadoop JobClient.getQueues() 不显示公平调度程序池

Question

调用 JobClient 类的 getQueues() 方法似乎只返回“默认”队列，即使公平调度程序已创建其他池并且正在运行作业。我想知道“池”和“队列”之间是否存在概念上的不匹配，但是为非默认池调用 getJobsFromQueue() 方法似乎工作得非常愉快。

是否有使用 JobClient 类从 Fair Scheduler 获取队列（或池？）名称的编程方式？或者是其他东西？

我应该补充一点，我在 Cloudera cdh4.0.1 上使用 Hadoop 2.0.0 MR1。

Answer 1

事实证明，您需要使用 mapred 站点配置文件中的 mapred.queue.names 属性将 Fair Scheduler 池明确命名为队列。