Repository: storm Updated Branches: refs/heads/master f37a6bd99 -> d3a74eec5
STORM-2903: (follow up) Log token identifier and username associated with token identifier Project: http://git-wip-us.apache.org/repos/asf/storm/repo Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/84158615 Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/84158615 Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/84158615 Branch: refs/heads/master Commit: 841586151e241beb87a42d55f5a7a500428b0c99 Parents: 05771ba Author: Manikumar Reddy <[email protected]> Authored: Mon Jan 22 15:40:10 2018 +0530 Committer: Manikumar Reddy <[email protected]> Committed: Mon Jan 22 15:59:46 2018 +0530 ---------------------------------------------------------------------- .../java/org/apache/storm/common/AbstractHadoopAutoCreds.java | 6 ++++++ 1 file changed, 6 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/storm/blob/84158615/external/storm-autocreds/src/main/java/org/apache/storm/common/AbstractHadoopAutoCreds.java ---------------------------------------------------------------------- diff --git a/external/storm-autocreds/src/main/java/org/apache/storm/common/AbstractHadoopAutoCreds.java b/external/storm-autocreds/src/main/java/org/apache/storm/common/AbstractHadoopAutoCreds.java index 936d1fc..2f62ee5 100644 --- a/external/storm-autocreds/src/main/java/org/apache/storm/common/AbstractHadoopAutoCreds.java +++ b/external/storm-autocreds/src/main/java/org/apache/storm/common/AbstractHadoopAutoCreds.java @@ -121,6 +121,12 @@ public abstract class AbstractHadoopAutoCreds implements IAutoCredentials, Crede LOG.debug("Current user: {}", UserGroupInformation.getCurrentUser()); LOG.debug("Token from Credentials : {}", token); + TokenIdentifier tokenId = token.decodeIdentifier(); + if (tokenId != null) { + LOG.debug("Token identifier : {}", tokenId); + LOG.debug("Username in token identifier : {}", tokenId.getUser()); + } + UserGroupInformation.getCurrentUser().addToken(token); LOG.info("Added delegation tokens to UGI."); } catch (IOException e) {
