From 3bc31e35a66491694ce414fef8948ae71e7e134f Mon Sep 17 00:00:00 2001 From: Vinod Kumar Vavilapalli Date: Wed, 5 Nov 2014 15:29:55 -0800 Subject: [PATCH] YARN-2805. Fixed ResourceManager to load HA configs correctly before kerberos login. Contributed by Wangda Tan. (cherry picked from commit 834e931d8efe4d806347b266e7e62929ce05389b) --- hadoop-yarn-project/CHANGES.txt | 3 +++ .../yarn/server/resourcemanager/ResourceManager.java | 11 ++++++----- 2 files changed, 9 insertions(+), 5 deletions(-) diff --git a/hadoop-yarn-project/CHANGES.txt b/hadoop-yarn-project/CHANGES.txt index 44e37284902..58b601ae79c 100644 --- a/hadoop-yarn-project/CHANGES.txt +++ b/hadoop-yarn-project/CHANGES.txt @@ -838,6 +838,9 @@ Release 2.6.0 - UNRELEASED YARN-2767. Added a test case to verify that http static user cannot kill or submit apps in the secure mode. (Varun Vasudev via zjshen) + YARN-2805. Fixed ResourceManager to load HA configs correctly before kerberos + login. (Wangda Tan via vinodkv) + Release 2.5.2 - UNRELEASED INCOMPATIBLE CHANGES diff --git a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/main/java/org/apache/hadoop/yarn/server/resourcemanager/ResourceManager.java b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/main/java/org/apache/hadoop/yarn/server/resourcemanager/ResourceManager.java index 642c73220f9..6adc73a6134 100644 --- a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/main/java/org/apache/hadoop/yarn/server/resourcemanager/ResourceManager.java +++ b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/main/java/org/apache/hadoop/yarn/server/resourcemanager/ResourceManager.java @@ -194,6 +194,12 @@ public class ResourceManager extends CompositeService implements Recoverable { this.conf = conf; this.rmContext = new RMContextImpl(); + // Set HA configuration should be done before login + this.rmContext.setHAEnabled(HAUtil.isHAEnabled(this.conf)); + if (this.rmContext.isHAEnabled()) { + HAUtil.verifyAndSetConfiguration(this.conf); + } + // Set UGI and do login // If security is enabled, use login user // If security is not enabled, use current user @@ -245,11 +251,6 @@ public class ResourceManager extends CompositeService implements Recoverable { adminService = createAdminService(); addService(adminService); rmContext.setRMAdminService(adminService); - - this.rmContext.setHAEnabled(HAUtil.isHAEnabled(this.conf)); - if (this.rmContext.isHAEnabled()) { - HAUtil.verifyAndSetConfiguration(this.conf); - } createAndInitActiveServices();