Apache
/
hadoop
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

HDFS-11069. Tighten the authorization of datanode RPC. Contributed by Kihwal Lee 

(cherry picked from commit ae48c496dc)
This commit is contained in:
Kihwal Lee 2016-10-27 14:18:48 -05:00
parent 5b0d32b4aa
commit 40dbf2a18d
1 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/datanode/DataNode.java
View File

@ -982,7 +982,7 @@ public class DataNode extends ReconfigurableBase
// Is this by the DN user itself? // Is this by the DN user itself?
assert dnUserName != null; assert dnUserName != null;
if (callerUgi.getShortUserName().equals(dnUserName)) { if (callerUgi.getUserName().equals(dnUserName)) {
return; return;
} }
@ -1300,7 +1300,7 @@ public class DataNode extends ReconfigurableBase
this.blockPoolTokenSecretManager = new BlockPoolTokenSecretManager(); this.blockPoolTokenSecretManager = new BlockPoolTokenSecretManager();
// Login is done by now. Set the DN user name. // Login is done by now. Set the DN user name.
dnUserName = UserGroupInformation.getCurrentUser().getShortUserName(); dnUserName = UserGroupInformation.getCurrentUser().getUserName();
LOG.info("dnUserName = " + dnUserName); LOG.info("dnUserName = " + dnUserName);
LOG.info("supergroup = " + supergroup); LOG.info("supergroup = " + supergroup);
initIpcServer(conf); initIpcServer(conf);
@ -3307,4 +3307,4 @@ public class DataNode extends ReconfigurableBase
void setBlockScanner(BlockScanner blockScanner) { void setBlockScanner(BlockScanner blockScanner) {
this.blockScanner = blockScanner; this.blockScanner = blockScanner;
} }
} }