Repository: hive Updated Branches: refs/heads/llap 9f999f252 -> 6d1b6bb40
HIVE-13672: Use loginUser from UGI to get llap user when generating LLAP splits. Project: http://git-wip-us.apache.org/repos/asf/hive/repo Commit: http://git-wip-us.apache.org/repos/asf/hive/commit/6d1b6bb4 Tree: http://git-wip-us.apache.org/repos/asf/hive/tree/6d1b6bb4 Diff: http://git-wip-us.apache.org/repos/asf/hive/diff/6d1b6bb4 Branch: refs/heads/llap Commit: 6d1b6bb40ab4b6ebedc721ed76d9a17a200ccca9 Parents: 9f999f2 Author: Jason Dere <[email protected]> Authored: Mon May 2 15:07:24 2016 -0700 Committer: Jason Dere <[email protected]> Committed: Mon May 2 15:07:24 2016 -0700 ---------------------------------------------------------------------- ql/pom.xml | 6 ------ .../hadoop/hive/ql/udf/generic/GenericUDTFGetSplits.java | 4 ++-- 2 files changed, 2 insertions(+), 8 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/hive/blob/6d1b6bb4/ql/pom.xml ---------------------------------------------------------------------- diff --git a/ql/pom.xml b/ql/pom.xml index 1f63b9f..aaa3271 100644 --- a/ql/pom.xml +++ b/ql/pom.xml @@ -291,12 +291,6 @@ <version>${hadoop.version}</version> <optional>true</optional> </dependency> - <dependency> - <groupId>org.apache.hadoop</groupId> - <artifactId>hadoop-yarn-registry</artifactId> - <version>${hadoop.version}</version> - <optional>true</optional> - </dependency> <dependency> <groupId>org.apache.ivy</groupId> http://git-wip-us.apache.org/repos/asf/hive/blob/6d1b6bb4/ql/src/java/org/apache/hadoop/hive/ql/udf/generic/GenericUDTFGetSplits.java ---------------------------------------------------------------------- diff --git a/ql/src/java/org/apache/hadoop/hive/ql/udf/generic/GenericUDTFGetSplits.java b/ql/src/java/org/apache/hadoop/hive/ql/udf/generic/GenericUDTFGetSplits.java index 2d36e5c..50cdadb 100644 --- a/ql/src/java/org/apache/hadoop/hive/ql/udf/generic/GenericUDTFGetSplits.java +++ b/ql/src/java/org/apache/hadoop/hive/ql/udf/generic/GenericUDTFGetSplits.java @@ -84,7 +84,7 @@ import org.apache.hadoop.io.DataOutputBuffer; import org.apache.hadoop.mapred.InputSplit; import org.apache.hadoop.mapred.JobConf; import org.apache.hadoop.mapred.SplitLocationInfo; -import org.apache.hadoop.registry.client.binding.RegistryUtils; +import org.apache.hadoop.security.UserGroupInformation; import org.apache.hadoop.yarn.api.records.ApplicationId; import org.apache.hadoop.yarn.api.records.LocalResource; import org.apache.hadoop.yarn.api.records.LocalResourceType; @@ -323,7 +323,7 @@ public class GenericUDTFGetSplits extends GenericUDTF { ApplicationId fakeApplicationId = ApplicationId.newInstance(Math.abs(new Random().nextInt()), 0); - String llapUser = RegistryUtils.currentUser(); + String llapUser = UserGroupInformation.getLoginUser().getShortUserName(); LOG.info("Number of splits: " + (eventList.size() - 1)); for (int i = 0; i < eventList.size() - 1; i++) {
