diff --git a/hbase-common/src/main/java/org/apache/hadoop/hbase/nio/MultiByteBuff.java b/hbase-common/src/main/java/org/apache/hadoop/hbase/nio/MultiByteBuff.java index 003e2305fb97..a3c0b5c528c7 100644 --- a/hbase-common/src/main/java/org/apache/hadoop/hbase/nio/MultiByteBuff.java +++ b/hbase-common/src/main/java/org/apache/hadoop/hbase/nio/MultiByteBuff.java @@ -1148,6 +1148,9 @@ private int internalRead(ReadableByteChannel channel, long offset, ChannelReader offset += len; } if (buffer.hasRemaining()) { + // reset + curItem = buffer; + curItemIndex = (curItemIndex - 1); break; } }