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