diff --git ql/src/java/org/apache/hadoop/hive/ql/exec/tez/TezTask.java ql/src/java/org/apache/hadoop/hive/ql/exec/tez/TezTask.java index 84ae157b12..a15482f19c 100644 --- ql/src/java/org/apache/hadoop/hive/ql/exec/tez/TezTask.java +++ ql/src/java/org/apache/hadoop/hive/ql/exec/tez/TezTask.java @@ -160,7 +160,11 @@ public int execute(DriverContext driverContext) { if (userName == null) { userName = "anonymous"; } else { - groups = UserGroupInformation.createRemoteUser(userName).getGroups(); + try { + groups = UserGroupInformation.createRemoteUser(userName).getGroups(); + } catch (Exception ex) { + LOG.warn("Cannot obtain groups for " + userName, ex); + } } MappingInput mi = new MappingInput(userName, groups, ss.getHiveVariables().get("wmpool"), ss.getHiveVariables().get("wmapp"));