You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hbase.apache.org by te...@apache.org on 2013/03/19 19:06:41 UTC
svn commit: r1458439 -
/hbase/branches/0.94/src/main/java/org/apache/hadoop/hbase/io/hfile/Compression.java
Author: tedyu
Date: Tue Mar 19 18:06:41 2013
New Revision: 1458439
URL: http://svn.apache.org/r1458439
Log:
HBASE-8125 HBASE-7435 breaks BuiltInGzipDecompressor on Hadoop < 1.0.x, real fix (Ted Yu)
Modified:
hbase/branches/0.94/src/main/java/org/apache/hadoop/hbase/io/hfile/Compression.java
Modified: hbase/branches/0.94/src/main/java/org/apache/hadoop/hbase/io/hfile/Compression.java
URL: http://svn.apache.org/viewvc/hbase/branches/0.94/src/main/java/org/apache/hadoop/hbase/io/hfile/Compression.java?rev=1458439&r1=1458438&r2=1458439&view=diff
==============================================================================
--- hbase/branches/0.94/src/main/java/org/apache/hadoop/hbase/io/hfile/Compression.java (original)
+++ hbase/branches/0.94/src/main/java/org/apache/hadoop/hbase/io/hfile/Compression.java Tue Mar 19 18:06:41 2013
@@ -352,7 +352,8 @@ public final class Compression {
Annotation[] annotations = decompressor.getClass().getAnnotations();
if (annotations != null) {
for (Annotation annotation : annotations) {
- if (annotation.getClass().getSimpleName().equals("DoNotPool")) {
+ String annoName = annotation.annotationType().getSimpleName();
+ if (annoName.equals("DoNotPool")) {
decompressor.end();
}
}