drill-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From ar...@apache.org
Subject [03/17] drill git commit: DRILL-6195: Quering Hive non-partitioned transactional tables via Drill
Date Sat, 03 Mar 2018 18:47:09 GMT
DRILL-6195: Quering Hive non-partitioned transactional tables via Drill

closes #1140


Project: http://git-wip-us.apache.org/repos/asf/drill/repo
Commit: http://git-wip-us.apache.org/repos/asf/drill/commit/6bf04ecc
Tree: http://git-wip-us.apache.org/repos/asf/drill/tree/6bf04ecc
Diff: http://git-wip-us.apache.org/repos/asf/drill/diff/6bf04ecc

Branch: refs/heads/master
Commit: 6bf04eccf4ab756fa370f800f2d35d2443bac518
Parents: 4112536
Author: Vitalii Diravka <vitalii.diravka@gmail.com>
Authored: Wed Feb 28 14:16:17 2018 +0000
Committer: Arina Ielchiieva <arina.yelchiyeva@gmail.com>
Committed: Sat Mar 3 19:47:35 2018 +0200

----------------------------------------------------------------------
 .../apache/drill/exec/store/hive/readers/HiveAbstractReader.java  | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/drill/blob/6bf04ecc/contrib/storage-hive/core/src/main/java/org/apache/drill/exec/store/hive/readers/HiveAbstractReader.java
----------------------------------------------------------------------
diff --git a/contrib/storage-hive/core/src/main/java/org/apache/drill/exec/store/hive/readers/HiveAbstractReader.java
b/contrib/storage-hive/core/src/main/java/org/apache/drill/exec/store/hive/readers/HiveAbstractReader.java
index b814866..a922b4c 100644
--- a/contrib/storage-hive/core/src/main/java/org/apache/drill/exec/store/hive/readers/HiveAbstractReader.java
+++ b/contrib/storage-hive/core/src/main/java/org/apache/drill/exec/store/hive/readers/HiveAbstractReader.java
@@ -153,7 +153,7 @@ public abstract class HiveAbstractReader extends AbstractRecordReader
{
         finalOI = (StructObjectInspector)ObjectInspectorConverters.getConvertedOI(partitionOI,
tableOI);
         partTblObjectInspectorConverter = ObjectInspectorConverters.getConverter(partitionOI,
finalOI);
         job.setInputFormat(HiveUtilities.getInputFormatClass(job, partition.getSd(), table));
-        HiveUtilities.verifyAndAddTransactionalProperties(job, table.getSd());
+        HiveUtilities.verifyAndAddTransactionalProperties(job, partition.getSd());
       } else {
         // For non-partitioned tables, there is no need to create converter as there are
no schema changes expected.
         partitionDeserializer = tableDeserializer;
@@ -161,6 +161,7 @@ public abstract class HiveAbstractReader extends AbstractRecordReader
{
         partTblObjectInspectorConverter = null;
         finalOI = tableOI;
         job.setInputFormat(HiveUtilities.getInputFormatClass(job, table.getSd(), table));
+        HiveUtilities.verifyAndAddTransactionalProperties(job, table.getSd());
       }
 
       if (logger.isTraceEnabled()) {


Mime
View raw message