Index: src/main/java/org/apache/hadoop/hbase/io/hfile/Compression.java =================================================================== --- src/main/java/org/apache/hadoop/hbase/io/hfile/Compression.java (revision 1425723) +++ src/main/java/org/apache/hadoop/hbase/io/hfile/Compression.java (working copy) @@ -33,6 +33,7 @@ import org.apache.hadoop.io.compress.CompressionOutputStream; import org.apache.hadoop.io.compress.Compressor; import org.apache.hadoop.io.compress.Decompressor; +import org.apache.hadoop.io.compress.DoNotPool; import org.apache.hadoop.io.compress.GzipCodec; import org.apache.hadoop.io.compress.DefaultCodec; import org.apache.hadoop.util.ReflectionUtils; @@ -308,6 +309,9 @@ public void returnDecompressor(Decompressor decompressor) { if (decompressor != null) { CodecPool.returnDecompressor(decompressor); + if (decompressor.getClass().isAnnotationPresent(DoNotPool.class)) { + decompressor.end(); + } } }