Index: ql/src/java/org/apache/hadoop/hive/ql/io/CombineHiveInputFormat.java =================================================================== --- ql/src/java/org/apache/hadoop/hive/ql/io/CombineHiveInputFormat.java (revision 888452) +++ ql/src/java/org/apache/hadoop/hive/ql/io/CombineHiveInputFormat.java (working copy) @@ -287,6 +287,22 @@ reporter, CombineHiveRecordReader.class); } + protected static partitionDesc getPartitionDescFromPath( + Map pathToPartitionInfo, Path dir) throws IOException { + // The format of the keys in pathToPartitionInfo sometimes contains a port + // and sometimes doesn't, so we just compare paths. + for (Map.Entry entry : pathToPartitionInfo.entrySet()) { + try { + if (new URI(entry.getKey()).getPath().equals(dir.toUri().getPath())) { + return entry.getValue(); + } + } + catch (URISyntaxException e2) {} + } + throw new IOException("cannot find dir = " + dir.toString() + + " in partToPartitionInfo!"); + } + static class CombineFilter implements PathFilter { private String pString;