You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hbase.apache.org by te...@apache.org on 2016/06/10 22:17:05 UTC
hbase git commit: HBASE-16006 FileSystem should be obtained from
specified path in WALInputFormat#getSplits()
Repository: hbase
Updated Branches:
refs/heads/HBASE-7912 5901cbbe6 -> 403697cd6
HBASE-16006 FileSystem should be obtained from specified path in WALInputFormat#getSplits()
Project: http://git-wip-us.apache.org/repos/asf/hbase/repo
Commit: http://git-wip-us.apache.org/repos/asf/hbase/commit/403697cd
Tree: http://git-wip-us.apache.org/repos/asf/hbase/tree/403697cd
Diff: http://git-wip-us.apache.org/repos/asf/hbase/diff/403697cd
Branch: refs/heads/HBASE-7912
Commit: 403697cd6881f6cc6591d076399a05b2bd285e3e
Parents: 5901cbb
Author: tedyu <yu...@gmail.com>
Authored: Fri Jun 10 15:16:48 2016 -0700
Committer: Ted <yu...@gmail.com>
Committed: Fri Jun 10 15:16:48 2016 -0700
----------------------------------------------------------------------
.../java/org/apache/hadoop/hbase/mapreduce/WALInputFormat.java | 3 +--
1 file changed, 1 insertion(+), 2 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/hbase/blob/403697cd/hbase-server/src/main/java/org/apache/hadoop/hbase/mapreduce/WALInputFormat.java
----------------------------------------------------------------------
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<WALKey, WALEdit> {
long startTime = conf.getLong(startKey, Long.MIN_VALUE);
long endTime = conf.getLong(endKey, Long.MAX_VALUE);
- FileSystem fs = FileSystem.get(conf);
-
List<FileStatus> allFiles = new ArrayList<FileStatus>();
for(Path inputPath: inputPaths){
+ FileSystem fs = inputPath.getFileSystem(conf);
List<FileStatus> files = getFiles(fs, inputPath, startTime, endTime);
allFiles.addAll(files);
}