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 {
