diff --git src/main/java/org/apache/hadoop/hbase/mapreduce/LoadIncrementalHFiles.java src/main/java/org/apache/hadoop/hbase/mapreduce/LoadIncrementalHFiles.java index cba9263..256debf 100644 --- src/main/java/org/apache/hadoop/hbase/mapreduce/LoadIncrementalHFiles.java +++ src/main/java/org/apache/hadoop/hbase/mapreduce/LoadIncrementalHFiles.java @@ -643,6 +643,11 @@ public class LoadIncrementalHFiles extends Configured implements Tool { new CacheConfig(getConf())); final byte[] first, last; try { + if (hcd.getCompressionType() != reader.getCompressionAlgorithm()) { + hcd.setCompressionType(reader.getCompressionAlgorithm()); + LOG.info("Setting compression " + hcd.getCompressionType().name() + + " for family " + hcd.toString()); + } reader.loadFileInfo(); first = reader.getFirstRowKey(); last = reader.getLastRowKey();