hadoop-common-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From bra...@apache.org
Subject [3/3] hadoop git commit: HDFS-8693. Addendum patch to execute the command using UGI. Contributed by Brahma Reddy Battula.
Date Mon, 12 Feb 2018 16:48:52 GMT
HDFS-8693. Addendum patch to execute the command using UGI. Contributed by Brahma Reddy Battula.

(cherry picked from commit 35c17351cab645dcc72e0d2ae1608507aa787ffb)


Project: http://git-wip-us.apache.org/repos/asf/hadoop/repo
Commit: http://git-wip-us.apache.org/repos/asf/hadoop/commit/055d5e0b
Tree: http://git-wip-us.apache.org/repos/asf/hadoop/tree/055d5e0b
Diff: http://git-wip-us.apache.org/repos/asf/hadoop/diff/055d5e0b

Branch: refs/heads/branch-3.0
Commit: 055d5e0b851b16c0f604bd66b022338694901164
Parents: 41cf2b8
Author: Brahma Reddy Battula <brahma@apache.org>
Authored: Mon Feb 12 22:14:34 2018 +0530
Committer: Brahma Reddy Battula <brahma@apache.org>
Committed: Mon Feb 12 22:17:35 2018 +0530

----------------------------------------------------------------------
 .../hdfs/server/datanode/BlockPoolManager.java       | 15 ++++++++++++++-
 1 file changed, 14 insertions(+), 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/hadoop/blob/055d5e0b/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/datanode/BlockPoolManager.java
----------------------------------------------------------------------
diff --git a/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/datanode/BlockPoolManager.java
b/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/datanode/BlockPoolManager.java
index f6a11c2..141550e 100644
--- a/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/datanode/BlockPoolManager.java
+++ b/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/datanode/BlockPoolManager.java
@@ -253,7 +253,20 @@ class BlockPoolManager {
           lifelineAddrs.add(nnIdToLifelineAddr != null ?
               nnIdToLifelineAddr.get(nnId) : null);
         }
-        bpos.refreshNNList(addrs, lifelineAddrs);
+        try {
+          UserGroupInformation.getLoginUser()
+              .doAs(new PrivilegedExceptionAction<Object>() {
+                @Override
+                public Object run() throws Exception {
+                  bpos.refreshNNList(addrs, lifelineAddrs);
+                  return null;
+                }
+              });
+        } catch (InterruptedException ex) {
+          IOException ioe = new IOException();
+          ioe.initCause(ex.getCause());
+          throw ioe;
+        }
       }
     }
   }


---------------------------------------------------------------------
To unsubscribe, e-mail: common-commits-unsubscribe@hadoop.apache.org
For additional commands, e-mail: common-commits-help@hadoop.apache.org


Mime
View raw message