diff --git ql/src/java/org/apache/hadoop/hive/ql/DriverUtils.java ql/src/java/org/apache/hadoop/hive/ql/DriverUtils.java index a2c6862936..f31b15687d 100644 --- ql/src/java/org/apache/hadoop/hive/ql/DriverUtils.java +++ ql/src/java/org/apache/hadoop/hive/ql/DriverUtils.java @@ -47,7 +47,7 @@ public static void runOnDriver(HiveConf conf, String user, SessionState.setCurrentSessionState(sessionState); boolean isOk = false; try { - QueryState qs = new QueryState.Builder().withHiveConf(conf).nonIsolated().build(); + QueryState qs = new QueryState.Builder().withHiveConf(conf).withGenerateNewQueryId(true).nonIsolated().build(); Driver driver = new Driver(qs, user, null, null); driver.setCompactionWriteIds(writeIds, compactorTxnId); try { diff --git ql/src/java/org/apache/hadoop/hive/ql/txn/compactor/CompactorMR.java ql/src/java/org/apache/hadoop/hive/ql/txn/compactor/CompactorMR.java index dc05e1990e..1757cc600f 100644 --- ql/src/java/org/apache/hadoop/hive/ql/txn/compactor/CompactorMR.java +++ ql/src/java/org/apache/hadoop/hive/ql/txn/compactor/CompactorMR.java @@ -352,7 +352,7 @@ private void runMmCompaction(HiveConf conf, Table t, Partition p, //thinking it already has a txn opened String user = UserGroupInformation.getCurrentUser().getShortUserName(); - SessionState sessionState = DriverUtils.setUpSessionState(driverConf, user, false); + SessionState sessionState = DriverUtils.setUpSessionState(driverConf, user, true); // Note: we could skip creating the table and just add table type stuff directly to the // "insert overwrite directory" command if there were no bucketing or list bucketing.