diff --git a/hbase-server/src/main/java/org/apache/hadoop/hbase/mapreduce/WALInputFormat.java b/hbase-server/src/main/java/org/apache/hadoop/hbase/mapreduce/WALInputFormat.java index 736b8a5..2fa7a70 100644 --- a/hbase-server/src/main/java/org/apache/hadoop/hbase/mapreduce/WALInputFormat.java +++ b/hbase-server/src/main/java/org/apache/hadoop/hbase/mapreduce/WALInputFormat.java @@ -239,10 +239,9 @@ public class WALInputFormat extends InputFormat { long startTime = conf.getLong(startKey, Long.MIN_VALUE); long endTime = conf.getLong(endKey, Long.MAX_VALUE); - FileSystem fs = FileSystem.get(conf); - List allFiles = new ArrayList(); for(Path inputPath: inputPaths){ + FileSystem fs = inputPath.getFileSystem(conf); List files = getFiles(fs, inputPath, startTime, endTime); allFiles.addAll(files); }