Repository: hive
Updated Branches:
  refs/heads/branch-3 b9c0a49de -> 1ead9e248


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/1ead9e24
Tree: http://git-wip-us.apache.org/repos/asf/hive/tree/1ead9e24
Diff: http://git-wip-us.apache.org/repos/asf/hive/diff/1ead9e24

Branch: refs/heads/branch-3
Commit: 1ead9e248ba81dd12ef32cfd8d5bec51ddcc17b9
Parents: b9c0a49
Author: Eric Wohlstadter <[email protected]>
Authored: Fri Jun 8 11:24:30 2018 -0700
Committer: Ashutosh Chauhan <[email protected]>
Committed: Fri Jun 8 11:25: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/1ead9e24/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