Repository: hive
Updated Branches:
  refs/heads/master a0c465d1c -> 920cc8159


HIVE-19808 : GenericUDTFGetSplits should support ACID reads in the temp. table 
read path (Eric Wohlstadter via Jason Dere)

Signed-off-by: Ashutosh Chauhan <[email protected]>


Project: http://git-wip-us.apache.org/repos/asf/hive/repo
Commit: http://git-wip-us.apache.org/repos/asf/hive/commit/920cc815
Tree: http://git-wip-us.apache.org/repos/asf/hive/tree/920cc815
Diff: http://git-wip-us.apache.org/repos/asf/hive/diff/920cc815

Branch: refs/heads/master
Commit: 920cc8159cb2c2b369a3c266eec807502bec442a
Parents: a0c465d
Author: Eric Wohlstadter <[email protected]>
Authored: Fri Jun 8 11:24:30 2018 -0700
Committer: Ashutosh Chauhan <[email protected]>
Committed: Fri Jun 8 11:24:30 2018 -0700

----------------------------------------------------------------------
 .../org/apache/hadoop/hive/ql/udf/generic/GenericUDTFGetSplits.java | 1 +
 1 file changed, 1 insertion(+)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/hive/blob/920cc815/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 20d0961..25a0ef2 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
@@ -296,6 +296,7 @@ public class GenericUDTFGetSplits extends GenericUDTF {
         String storageFormatString = getTempTableStorageFormatString(conf);
         String ctas = "create temporary table " + tableName + " " + 
storageFormatString + " as " + query;
         LOG.info("Materializing the query for LLAPIF; CTAS: " + ctas);
+        driver.releaseLocksAndCommitOrRollback(false);
         driver.releaseResources();
         HiveConf.setVar(conf, ConfVars.HIVE_EXECUTION_MODE, originalMode);
         cpr = driver.run(ctas, false);

Reply via email to