diff --git a/src/main/java/org/apache/hadoop/hbase/io/encoding/FastDiffDeltaEncoder.java b/src/main/java/org/apache/hadoop/hbase/io/encoding/FastDiffDeltaEncoder.java index 0ca02c8..7959e0e 100644 --- a/src/main/java/org/apache/hadoop/hbase/io/encoding/FastDiffDeltaEncoder.java +++ b/src/main/java/org/apache/hadoop/hbase/io/encoding/FastDiffDeltaEncoder.java @@ -389,7 +389,7 @@ ByteBufferUtils.readCompressedInt(block); // commonLength int pos = block.position(); block.reset(); - return ByteBuffer.wrap(block.array(), pos, keyLength).slice(); + return ByteBuffer.wrap(block.array(), block.arrayOffset() + pos, keyLength).slice(); } @Override diff --git a/src/main/java/org/apache/hadoop/hbase/io/encoding/PrefixKeyDeltaEncoder.java b/src/main/java/org/apache/hadoop/hbase/io/encoding/PrefixKeyDeltaEncoder.java index ac63ead..3e4416f 100644 --- a/src/main/java/org/apache/hadoop/hbase/io/encoding/PrefixKeyDeltaEncoder.java +++ b/src/main/java/org/apache/hadoop/hbase/io/encoding/PrefixKeyDeltaEncoder.java @@ -154,7 +154,7 @@ } int pos = block.position(); block.reset(); - return ByteBuffer.wrap(block.array(), pos, keyLength).slice(); + return ByteBuffer.wrap(block.array(), block.arrayOffset() + pos, keyLength).slice(); } @Override