You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@drill.apache.org by ar...@apache.org on 2018/03/03 18:47:09 UTC
[03/17] drill git commit: DRILL-6195: Quering Hive non-partitioned
transactional tables via Drill
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 <vi...@gmail.com>
Authored: Wed Feb 28 14:16:17 2018 +0000
Committer: Arina Ielchiieva <ar...@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()) {