svn commit: r1221035 - in /hbase/branches/0.92: CHANGES.txt src/main/java/org/apache/hadoop/hbase/regionserver/wal/SequenceFileLogReader.java

[stack]

Author: stack
Date: Tue Dec 20 00:17:15 2011
New Revision: 1221035

URL: http://svn.apache.org/viewvc?rev=1221035&view=rev
Log:
HBASE-4935 hbase 0.92.0 doesn't work going against 0.20.205.0, its packaged 
hadoop

Modified:
    hbase/branches/0.92/CHANGES.txt
    
hbase/branches/0.92/src/main/java/org/apache/hadoop/hbase/regionserver/wal/SequenceFileLogReader.java

Modified: hbase/branches/0.92/CHANGES.txt
URL: 
http://svn.apache.org/viewvc/hbase/branches/0.92/CHANGES.txt?rev=1221035&r1=1221034&r2=1221035&view=diff
==============================================================================
--- hbase/branches/0.92/CHANGES.txt (original)
+++ hbase/branches/0.92/CHANGES.txt Tue Dec 20 00:17:15 2011
@@ -492,6 +492,7 @@ Release 0.92.0 - Unreleased
                (Jimmy Xiang)
    HBASE-5040  Secure HBase builds fail
    HBASE-5062  Missing logons if security is enabled
+   HBASE-4935  hbase 0.92.0 doesn't work going against 0.20.205.0, its 
packaged hadoop
 
   TESTS
    HBASE-4492  TestRollingRestart fails intermittently

Modified: 
hbase/branches/0.92/src/main/java/org/apache/hadoop/hbase/regionserver/wal/SequenceFileLogReader.java
URL: 
http://svn.apache.org/viewvc/hbase/branches/0.92/src/main/java/org/apache/hadoop/hbase/regionserver/wal/SequenceFileLogReader.java?rev=1221035&r1=1221034&r2=1221035&view=diff
==============================================================================
--- 
hbase/branches/0.92/src/main/java/org/apache/hadoop/hbase/regionserver/wal/SequenceFileLogReader.java
 (original)
+++ 
hbase/branches/0.92/src/main/java/org/apache/hadoop/hbase/regionserver/wal/SequenceFileLogReader.java
 Tue Dec 20 00:17:15 2011
@@ -106,7 +106,9 @@ public class SequenceFileLogReader imple
             Field fIn = FilterInputStream.class.getDeclaredField("in");
             fIn.setAccessible(true);
             Object realIn = fIn.get(this.in);
-            if (realIn.getClass() == DFSInputStream.class) {
+            // In hadoop 0.22, DFSInputStream is a standalone class.  Before 
this,
+            // it was an inner class of DFSClient.
+            if (realIn.getClass().getName().endsWith("DFSInputStream")) {
               Method getFileLength = realIn.getClass().
                 getDeclaredMethod("getFileLength", new Class<?> []{});
               getFileLength.setAccessible(true);