hbase-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From st...@apache.org
Subject svn commit: r810309 - /hadoop/hbase/branches/0.20/src/java/org/apache/hadoop/hbase/io/hfile/HFile.java
Date Tue, 01 Sep 2009 23:26:13 GMT
Author: stack
Date: Tue Sep  1 23:26:13 2009
New Revision: 810309

URL: http://svn.apache.org/viewvc?rev=810309&view=rev
Log:
HBASE-1784 Missing rows after medium intensity insert

Modified:
    hadoop/hbase/branches/0.20/src/java/org/apache/hadoop/hbase/io/hfile/HFile.java

Modified: hadoop/hbase/branches/0.20/src/java/org/apache/hadoop/hbase/io/hfile/HFile.java
URL: http://svn.apache.org/viewvc/hadoop/hbase/branches/0.20/src/java/org/apache/hadoop/hbase/io/hfile/HFile.java?rev=810309&r1=810308&r2=810309&view=diff
==============================================================================
--- hadoop/hbase/branches/0.20/src/java/org/apache/hadoop/hbase/io/hfile/HFile.java (original)
+++ hadoop/hbase/branches/0.20/src/java/org/apache/hadoop/hbase/io/hfile/HFile.java Tue Sep
 1 23:26:13 2009
@@ -967,9 +967,8 @@
     private ByteBuffer decompress(final long offset, final int compressedSize,
       final int decompressedSize) 
     throws IOException {
-      
       Decompressor decompressor = null;
-      
+      ByteBuffer buf = null;
       try {
         decompressor = this.compressAlgo.getDecompressor();
         // My guess is that the bounded range fis is needed to stop the 
@@ -979,7 +978,7 @@
         InputStream is = this.compressAlgo.createDecompressionStream(
           new BoundedRangeFileInputStream(this.istream, offset, compressedSize),
           decompressor, 0);
-        ByteBuffer buf = ByteBuffer.allocate(decompressedSize);
+        buf = ByteBuffer.allocate(decompressedSize);
         IOUtils.readFully(is, buf.array(), 0, buf.capacity());
         is.close();        
       } finally {



Mime
View raw message