From 655075f9cea5f41e2770924ceabee79a57ea323e Mon Sep 17 00:00:00 2001 From: Vitalii Diravka Date: Wed, 28 Feb 2018 14:16:17 +0000 Subject: [PATCH] DRILL-6195: Quering Hive non-partitioned transactional tables via Drill --- .../drill/exec/store/hive/readers/HiveAbstractReader.java | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) 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 b814866109f..a922b4ca060 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 @@ private void init() throws ExecutionSetupException { 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 @@ private void init() throws ExecutionSetupException { partTblObjectInspectorConverter = null; finalOI = tableOI; job.setInputFormat(HiveUtilities.getInputFormatClass(job, table.getSd(), table)); + HiveUtilities.verifyAndAddTransactionalProperties(job, table.getSd()); } if (logger.isTraceEnabled()) {