YARN-7692. Skip validating priority acls while recovering applications. Contributed by Sunil G.
Project: http://git-wip-us.apache.org/repos/asf/hadoop/repo Commit: http://git-wip-us.apache.org/repos/asf/hadoop/commit/c9bf813c Tree: http://git-wip-us.apache.org/repos/asf/hadoop/tree/c9bf813c Diff: http://git-wip-us.apache.org/repos/asf/hadoop/diff/c9bf813c Branch: refs/heads/YARN-6592 Commit: c9bf813c9a6c018d14f2bef49ba086ec0e60c761 Parents: c0c7cce Author: Rohith Sharma K S <rohithsharm...@apache.org> Authored: Wed Jan 3 18:20:04 2018 +0530 Committer: Rohith Sharma K S <rohithsharm...@apache.org> Committed: Wed Jan 3 18:20:04 2018 +0530 ---------------------------------------------------------------------- .../yarn/server/resourcemanager/RMAppManager.java | 14 ++++++++++---- 1 file changed, 10 insertions(+), 4 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/hadoop/blob/c9bf813c/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/main/java/org/apache/hadoop/yarn/server/resourcemanager/RMAppManager.java ---------------------------------------------------------------------- diff --git a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/main/java/org/apache/hadoop/yarn/server/resourcemanager/RMAppManager.java b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/main/java/org/apache/hadoop/yarn/server/resourcemanager/RMAppManager.java index 5ea1152..2983077 100644 --- a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/main/java/org/apache/hadoop/yarn/server/resourcemanager/RMAppManager.java +++ b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/main/java/org/apache/hadoop/yarn/server/resourcemanager/RMAppManager.java @@ -393,10 +393,16 @@ public class RMAppManager implements EventHandler<RMAppManagerEvent>, // Verify and get the update application priority and set back to // submissionContext UserGroupInformation userUgi = UserGroupInformation.createRemoteUser(user); - Priority appPriority = scheduler.checkAndGetApplicationPriority( - submissionContext.getPriority(), userUgi, submissionContext.getQueue(), - applicationId); - submissionContext.setPriority(appPriority); + + // Application priority needed to be validated only while submitting. During + // recovery, validated priority could be recovered from submission context. + if (!isRecovery) { + Priority appPriority = scheduler.checkAndGetApplicationPriority( + submissionContext.getPriority(), userUgi, + submissionContext.getQueue(), + applicationId); + submissionContext.setPriority(appPriority); + } // Since FairScheduler queue mapping is done inside scheduler, // if FairScheduler is used and the queue doesn't exist, we should not --------------------------------------------------------------------- To unsubscribe, e-mail: common-commits-unsubscr...@hadoop.apache.org For additional commands, e-mail: common-commits-h...@hadoop.apache.org