commit 314fe4da33065c0eb151b173e8301b9352e4b767
author Volodymyr Vysotskyi <vvovyk@gmail.com> Tue Sep 01 17:36:42 2020 +0300
committer Volodymyr Vysotskyi <vvovyk@gmail.com> Mon Sep 14 19:31:29 2020 +0300
tree 0f51ad4f8b9d01cd3e6b5f4fb9874d8dfbeb848b
parent f1b9742d352f5a88d70e7c8f7a67c5bedcd45cc2

DRILL-7785: Some hive tables fail with UndeclaredThrowableException

contrib/storage-hive/core/src/main/java/org/apache/drill/exec/store/hive/readers/HiveDefaultRecordReader.java

diff --git a/contrib/storage-hive/core/src/main/java/org/apache/drill/exec/store/hive/readers/HiveDefaultRecordReader.java b/contrib/storage-hive/core/src/main/java/org/apache/drill/exec/store/hive/readers/HiveDefaultRecordReader.java
index d490f5d..8598643 100644
--- a/contrib/storage-hive/core/src/main/java/org/apache/drill/exec/store/hive/readers/HiveDefaultRecordReader.java
+++ b/contrib/storage-hive/core/src/main/java/org/apache/drill/exec/store/hive/readers/HiveDefaultRecordReader.java
@@ -271,10 +271,13 @@
         this.partitionToTableSchemaConverter = (obj) -> obj;
         this.finalObjInspector = tableObjInspector;
 
+        HiveUtilities.addConfToJob(job, hiveTableProperties);
         job.setInputFormat(HiveUtilities.getInputFormatClass(job, hiveTable.getSd(), hiveTable));
         HiveUtilities.verifyAndAddTransactionalProperties(job, hiveTable.getSd());
       } else {
-        this.partitionDeserializer = createDeserializer(job, partition.getSd(), HiveUtilities.getPartitionMetadata(partition, hiveTable));
+        Properties partitionProperties = HiveUtilities.getPartitionMetadata(partition, hiveTable);
+        HiveUtilities.addConfToJob(job, partitionProperties);
+        this.partitionDeserializer = createDeserializer(job, partition.getSd(), partitionProperties);
         this.partitionObjInspector = getStructOI(partitionDeserializer);
 
         this.finalObjInspector = (StructObjectInspector) ObjectInspectorConverters.getConvertedOI(partitionObjInspector, tableObjInspector);