diff --git a/hbase-server/src/main/java/org/apache/hadoop/hbase/mapreduce/LoadIncrementalHFiles.java b/hbase-server/src/main/java/org/apache/hadoop/hbase/mapreduce/LoadIncrementalHFiles.java index a77ea01..7657571 100644 --- a/hbase-server/src/main/java/org/apache/hadoop/hbase/mapreduce/LoadIncrementalHFiles.java +++ b/hbase-server/src/main/java/org/apache/hadoop/hbase/mapreduce/LoadIncrementalHFiles.java @@ -207,7 +207,7 @@ public class LoadIncrementalHFiles extends Configured implements Tool { byte[] family = familyDir.getName().getBytes(); FileStatus[] hfileStatuses = fs.listStatus(familyDir); for (FileStatus hfileStatus : hfileStatuses) { - if (!hfileStatus.isFile()) { + if (!fs.isFile(hfileStatus.getPath())) { LOG.warn("Skipping non-file " + hfileStatus); continue; }