diff --git ql/src/java/org/apache/hadoop/hive/ql/io/HiveInputFormat.java ql/src/java/org/apache/hadoop/hive/ql/io/HiveInputFormat.java index 1338c5d..b20439c 100755 --- ql/src/java/org/apache/hadoop/hive/ql/io/HiveInputFormat.java +++ ql/src/java/org/apache/hadoop/hive/ql/io/HiveInputFormat.java @@ -236,7 +236,11 @@ public RecordReader getRecordReader(InputSplit split, JobConf job, } boolean nonNative = false; - PartitionDesc part = pathToPartitionInfo.get(hsplit.getPath().toString()); + PartitionDesc part = HiveFileFormatUtils.getPartitionDescFromPathRecursively( + pathToPartitionInfo, hsplit.getPath(), null); + if (LOG.isDebugEnabled()) { + LOG.debug("Found spec for " + hsplit.getPath() + " " + part + " from " + pathToPartitionInfo); + } if ((part != null) && (part.getTableDesc() != null)) { Utilities.copyTableJobPropertiesToConf(part.getTableDesc(), job); nonNative = part.getTableDesc().isNonNative();