Index: src/java/org/apache/hcatalog/mapreduce/HCatBaseInputFormat.java =================================================================== --- src/java/org/apache/hcatalog/mapreduce/HCatBaseInputFormat.java (revision 1408473) +++ src/java/org/apache/hcatalog/mapreduce/HCatBaseInputFormat.java (working copy) @@ -316,14 +316,15 @@ Path[] paths = StringUtils.stringToPath(pathStrings.toArray(new String[0])); - FileSystem fs = FileSystem.get(jobConf); - Path path = paths[0].makeQualified(fs); - StringBuilder str = new StringBuilder(StringUtils.escapeString( - path.toString())); - for (int i = 1; i < paths.length; i++) { - str.append(StringUtils.COMMA_STR); - path = paths[i].makeQualified(fs); - str.append(StringUtils.escapeString(path.toString())); + String separator = ""; + StringBuilder str = new StringBuilder(); + + for (Path path : paths) { + FileSystem fs = path.getFileSystem(jobConf); + final String qualifiedPath = path.makeQualified(fs).toString(); + str.append(separator) + .append(StringUtils.escapeString(qualifiedPath)); + separator = StringUtils.COMMA_STR; } jobConf.set("mapred.input.dir", str.toString());