diff --git src/main/java/org/apache/hadoop/hbase/mapreduce/LoadIncrementalHFiles.java src/main/java/org/apache/hadoop/hbase/mapreduce/LoadIncrementalHFiles.java index cba9263..6cb749e 100644 --- src/main/java/org/apache/hadoop/hbase/mapreduce/LoadIncrementalHFiles.java +++ src/main/java/org/apache/hadoop/hbase/mapreduce/LoadIncrementalHFiles.java @@ -631,11 +631,20 @@ public class LoadIncrementalHFiles extends Configured implements Tool { // Skip _logs, etc if (familyDir.getName().startsWith("_")) continue; byte[] family = familyDir.getName().getBytes(); - + + Path[] hfiles = FileUtil.stat2Paths(fs.listStatus(familyDir)); + + if (hfiles.length == 0) { + continue; + } + HFile.Reader hfileReader = HFile.createReader(fs, hfiles[0], new CacheConfig(getConf())); + Algorithm compression = hfileReader.getCompressionAlgorithm(); + hfileReader.close(); + hcd = new HColumnDescriptor(family); + hcd.setCompressionType(compression); htd.addFamily(hcd); - - Path[] hfiles = FileUtil.stat2Paths(fs.listStatus(familyDir)); + for (Path hfile : hfiles) { if (hfile.getName().startsWith("_")) continue;