diff --git ql/src/java/org/apache/hadoop/hive/ql/exec/tez/TezSessionState.java ql/src/java/org/apache/hadoop/hive/ql/exec/tez/TezSessionState.java index 3ea5ef9..21ff73f 100644 --- ql/src/java/org/apache/hadoop/hive/ql/exec/tez/TezSessionState.java +++ ql/src/java/org/apache/hadoop/hive/ql/exec/tez/TezSessionState.java @@ -271,7 +271,7 @@ protected void openInternal(final HiveConf conf, Collection additionalFi ServicePluginsDescriptor servicePluginsDescriptor; - Credentials llapCredentials = null; + Credentials sessionCredentials = UserGroupInformation.getCurrentUser().getCredentials(); if (llapMode) { if (UserGroupInformation.isSecurityEnabled()) { LlapTokenProvider tp = LlapProxy.getOrInitTokenProvider(conf); @@ -279,8 +279,7 @@ protected void openInternal(final HiveConf conf, Collection additionalFi if (LOG.isInfoEnabled()) { LOG.info("Obtained a LLAP token: " + token); } - llapCredentials = new Credentials(); - llapCredentials.addToken(LlapTokenIdentifier.KIND_NAME, token); + sessionCredentials.addToken(LlapTokenIdentifier.KIND_NAME, token); } UserPayload servicePluginPayload = TezUtils.createUserPayloadFromConf(tezConfig); // we need plugins to handle llap and uber mode @@ -306,7 +305,7 @@ protected void openInternal(final HiveConf conf, Collection additionalFi final TezClient session = TezClient.newBuilder("HIVE-" + sessionId, tezConfig) .setIsSession(true).setLocalResources(commonLocalResources) - .setCredentials(llapCredentials).setServicePluginDescriptor(servicePluginsDescriptor) + .setCredentials(sessionCredentials).setServicePluginDescriptor(servicePluginsDescriptor) .build(); LOG.info("Opening new Tez Session (id: " + sessionId