diff --git src/main/java/org/apache/hadoop/hbase/mapreduce/LoadIncrementalHFiles.java src/main/java/org/apache/hadoop/hbase/mapreduce/LoadIncrementalHFiles.java index cba9263..c19b643 100644 --- src/main/java/org/apache/hadoop/hbase/mapreduce/LoadIncrementalHFiles.java +++ src/main/java/org/apache/hadoop/hbase/mapreduce/LoadIncrementalHFiles.java @@ -643,6 +643,9 @@ public class LoadIncrementalHFiles extends Configured implements Tool { new CacheConfig(getConf())); final byte[] first, last; try { + if (hcd.getCompressionType() != reader.getCompressionAlgorithm()) { + hcd.setCompressionType(reader.getCompressionAlgorithm()); + } reader.loadFileInfo(); first = reader.getFirstRowKey(); last = reader.getLastRowKey();