Repository: hive Updated Branches: refs/heads/branch-1 ec94a95c4 -> 0e687fd46
"Alter index rebuild" statements submitted through HiveServer2 fail when Sentry is enabled (Aihua Xu, reviewed by Chao Sun and Ashutosh Chauhan) Project: http://git-wip-us.apache.org/repos/asf/hive/repo Commit: http://git-wip-us.apache.org/repos/asf/hive/commit/0e687fd4 Tree: http://git-wip-us.apache.org/repos/asf/hive/tree/0e687fd4 Diff: http://git-wip-us.apache.org/repos/asf/hive/diff/0e687fd4 Branch: refs/heads/branch-1 Commit: 0e687fd464d05c94422d49e9c540f82f7f3d7b4e Parents: ec94a95 Author: Aihua Xu <[email protected]> Authored: Sat Aug 29 12:58:42 2015 -0700 Committer: Chao Sun <[email protected]> Committed: Sat Aug 29 12:58:42 2015 -0700 ---------------------------------------------------------------------- .../apache/hadoop/hive/ql/optimizer/IndexUtils.java | 13 +++++++++---- 1 file changed, 9 insertions(+), 4 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/hive/blob/0e687fd4/ql/src/java/org/apache/hadoop/hive/ql/optimizer/IndexUtils.java ---------------------------------------------------------------------- diff --git a/ql/src/java/org/apache/hadoop/hive/ql/optimizer/IndexUtils.java b/ql/src/java/org/apache/hadoop/hive/ql/optimizer/IndexUtils.java index 92cae67..0b30258 100644 --- a/ql/src/java/org/apache/hadoop/hive/ql/optimizer/IndexUtils.java +++ b/ql/src/java/org/apache/hadoop/hive/ql/optimizer/IndexUtils.java @@ -49,6 +49,7 @@ import org.apache.hadoop.hive.ql.optimizer.physical.index.IndexWhereProcessor; import org.apache.hadoop.hive.ql.parse.ParseContext; import org.apache.hadoop.hive.ql.parse.PrunedPartitionList; import org.apache.hadoop.hive.ql.parse.SemanticException; +import org.apache.hadoop.hive.ql.session.SessionState; /** * Utility class for index support. @@ -213,13 +214,17 @@ public final class IndexUtils { return hive.getIndexes(table.getTTable().getDbName(), table.getTTable().getTableName(), max); } - public static Task<?> createRootTask(HiveConf builderConf, Set<ReadEntity> inputs, - Set<WriteEntity> outputs, StringBuilder command, + public static Task<?> createRootTask( + HiveConf builderConf, + Set<ReadEntity> inputs, + Set<WriteEntity> outputs, + StringBuilder command, LinkedHashMap<String, String> partSpec, - String indexTableName, String dbName){ + String indexTableName, + String dbName){ // Don't try to index optimize the query to build the index HiveConf.setBoolVar(builderConf, HiveConf.ConfVars.HIVEOPTINDEXFILTER, false); - Driver driver = new Driver(builderConf); + Driver driver = new Driver(builderConf, SessionState.get().getUserName()); driver.compile(command.toString(), false); Task<?> rootTask = driver.getPlan().getRootTasks().get(0);
