diff --git a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/main/java/org/apache/hadoop/yarn/server/resourcemanager/scheduler/capacity/CapacitySchedulerConfiguration.java b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/main/java/org/apache/hadoop/yarn/server/resourcemanager/scheduler/capacity/CapacitySchedulerConfiguration.java index adf5e6b81e..c1ce6da220 100644 --- a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/main/java/org/apache/hadoop/yarn/server/resourcemanager/scheduler/capacity/CapacitySchedulerConfiguration.java +++ b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/main/java/org/apache/hadoop/yarn/server/resourcemanager/scheduler/capacity/CapacitySchedulerConfiguration.java @@ -402,7 +402,7 @@ public CapacitySchedulerConfiguration(Configuration configuration, } } - static String getQueuePrefix(String queue) { + public static String getQueuePrefix(String queue) { String queueName = PREFIX + queue + DOT; return queueName; } diff --git a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/main/java/org/apache/hadoop/yarn/server/resourcemanager/webapp/dao/CapacitySchedulerQueueInfo.java b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/main/java/org/apache/hadoop/yarn/server/resourcemanager/webapp/dao/CapacitySchedulerQueueInfo.java index bde1bb1b71..f4d4070a89 100644 --- a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/main/java/org/apache/hadoop/yarn/server/resourcemanager/webapp/dao/CapacitySchedulerQueueInfo.java +++ b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/main/java/org/apache/hadoop/yarn/server/resourcemanager/webapp/dao/CapacitySchedulerQueueInfo.java @@ -131,7 +131,7 @@ public class CapacitySchedulerQueueInfo { CapacitySchedulerConfiguration conf = cs.getConfiguration(); queueAcls = new QueueAclsInfo(); for (Map.Entry e : conf - .getAcls(queueName).entrySet()) { + .getAcls(queuePath).entrySet()) { QueueAclInfo queueAcl = new QueueAclInfo(e.getKey().toString(), e.getValue().getAclString()); queueAcls.add(queueAcl); @@ -139,8 +139,8 @@ public class CapacitySchedulerQueueInfo { String aclApplicationMaxPriority = "acl_" + StringUtils.toLowerCase(AccessType.APPLICATION_MAX_PRIORITY.toString()); - String priorityAcls = conf.get(queuePath + aclApplicationMaxPriority, - conf.ALL_ACL); + String priorityAcls = conf.get(CapacitySchedulerConfiguration + .getQueuePrefix(queuePath) + aclApplicationMaxPriority, conf.ALL_ACL); QueueAclInfo queueAcl = new QueueAclInfo( AccessType.APPLICATION_MAX_PRIORITY.toString(), priorityAcls);