diff --git a/src/java/org/apache/sqoop/mapreduce/CombineFileInputFormat.java b/src/java/org/apache/sqoop/mapreduce/CombineFileInputFormat.java
index 7d2be385..e08f9978 100644
--- a/src/java/org/apache/sqoop/mapreduce/CombineFileInputFormat.java
+++ b/src/java/org/apache/sqoop/mapreduce/CombineFileInputFormat.java
@@ -224,7 +224,11 @@ public List<InputSplit> getSplits(JobContext job)
     // times, one time each for each pool in the next loop.
     List<Path> newpaths = new LinkedList<Path>();
     for (int i = 0; i < paths.length; i++) {
-      Path p = new Path(paths[i].toUri().getPath());
+      FileSystem fs = paths[i].getFileSystem(conf);
+
+      //the scheme and authority will be kept if the path is
+      //a valid path for a non-default file system
+      Path p = fs.makeQualified(paths[i]);
       newpaths.add(p);
     }
     paths = null;