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 bd64924..f6b624f 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 @@ -200,6 +200,12 @@ public class LoadIncrementalHFiles extends Configured implements Tool { continue; } Path familyDir = stat.getPath(); + if (familyDir.getName().equals("_logs")) { + // Family name of "_logs" is not supported. + // This is due to the presence of history directory under _logs directory + // when hadoop-1 is used + continue; + } byte[] family = familyDir.getName().getBytes(); Path[] hfiles = FileUtil.stat2Paths(fs.listStatus(familyDir)); for (Path hfile : hfiles) {