DRILL-1398: Clone HivePartition only when InputSplit has non-null partition in InputSplit->Partition map.
Project: http://git-wip-us.apache.org/repos/asf/incubator-drill/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-drill/commit/525bc79d Tree: http://git-wip-us.apache.org/repos/asf/incubator-drill/tree/525bc79d Diff: http://git-wip-us.apache.org/repos/asf/incubator-drill/diff/525bc79d Branch: refs/heads/master Commit: 525bc79da6100af3ba3f264ca9c61d56d7cb11f6 Parents: 2a45d95 Author: vkorukanti <venki.koruka...@gmail.com> Authored: Tue Sep 9 18:12:27 2014 -0700 Committer: Steven Phillips <sphill...@maprtech.com> Committed: Sun Sep 28 00:10:45 2014 -0700 ---------------------------------------------------------------------- .../main/java/org/apache/drill/exec/store/hive/HiveScan.java | 6 +++++- 1 file changed, 5 insertions(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-drill/blob/525bc79d/contrib/storage-hive/core/src/main/java/org/apache/drill/exec/store/hive/HiveScan.java ---------------------------------------------------------------------- diff --git a/contrib/storage-hive/core/src/main/java/org/apache/drill/exec/store/hive/HiveScan.java b/contrib/storage-hive/core/src/main/java/org/apache/drill/exec/store/hive/HiveScan.java index d7ef5bf..303fc3c 100644 --- a/contrib/storage-hive/core/src/main/java/org/apache/drill/exec/store/hive/HiveScan.java +++ b/contrib/storage-hive/core/src/main/java/org/apache/drill/exec/store/hive/HiveScan.java @@ -214,7 +214,11 @@ public class HiveScan extends AbstractGroupScan { List<String> encodedInputSplits = Lists.newArrayList(); List<String> splitTypes = Lists.newArrayList(); for (InputSplit split : splits) { - parts.add(new HiveTable.HivePartition(partitionMap.get(split))); + HivePartition partition = null; + if (partitionMap.get(split) != null) { + partition = new HivePartition(partitionMap.get(split)); + } + parts.add(partition); encodedInputSplits.add(serializeInputSplit(split)); splitTypes.add(split.getClass().getName()); }
