[
https://issues.apache.org/jira/browse/HBASE-8125?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13606599#comment-13606599
]
Ted Yu commented on HBASE-8125:
-------------------------------
How about this addendum ?
> HBASE-7435 breaks BuiltInGzipDecompressor on Hadoop < 1.0.x
> -----------------------------------------------------------
>
> Key: HBASE-8125
> URL: https://issues.apache.org/jira/browse/HBASE-8125
> Project: HBase
> Issue Type: Bug
> Reporter: stack
> Assignee: Ted Yu
> Fix For: 0.94.7
>
> Attachments: 8125-0.94.txt, 8125.addendum
>
>
> From some friends of ours at dropbox:
> 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();
> + }
> }
> }
> breaks compatibility with hadoop-0.20.2-cdh3u2.
> +import org.apache.hadoop.io.compress.DoNotPool;
> does not exist in that version of hadoop.
--
This message is automatically generated by JIRA.
If you think it was sent incorrectly, please contact your JIRA administrators
For more information on JIRA, see: http://www.atlassian.com/software/jira
