|
@@ -2686,10 +2686,10 @@ public class CapacityScheduler extends
|
|
|
}
|
|
|
|
|
|
// Lets check for ACLs here.
|
|
|
- if (!appPriorityACLManager.checkAccess(user, queuePath, appPriority)) {
|
|
|
+ if (!appPriorityACLManager.checkAccess(user, normalizeQueueName(queuePath), appPriority)) {
|
|
|
throw new YarnException(new AccessControlException(
|
|
|
- "User " + user + " does not have permission to submit/update "
|
|
|
- + applicationId + " for " + appPriority));
|
|
|
+ "User " + user + " does not have permission to submit/update "
|
|
|
+ + applicationId + " for " + appPriority));
|
|
|
}
|
|
|
|
|
|
LOG.info("Priority '" + appPriority.getPriority()
|