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 @@ ${hadoop.version} true - - org.apache.hadoop - hadoop-yarn-registry - ${hadoop.version} - true - org.apache.ivy 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.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 PlanFragment createPlanFragment(String query, int num) throws HiveExcepti 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++) {