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 <[email protected]> Authored: Wed Feb 28 14:16:17 2018 +0000 Committer: Arina Ielchiieva <[email protected]> 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()) {
