(tsfile) branch develop updated: Fix uncompress page data (#161)

[jiangtian]

This is an automated email from the ASF dual-hosted git repository.

jiangtian pushed a commit to branch develop
in repository https://gitbox.apache.org/repos/asf/tsfile.git


The following commit(s) were added to refs/heads/develop by this push:
     new 625d05b0 Fix uncompress page data (#161)
625d05b0 is described below

commit 625d05b05e9f08fede52555ee441f3d721bb6037
Author: shuwenwei <55970239+shuwen...@users.noreply.github.com>
AuthorDate: Fri Jul 5 19:35:50 2024 +0800

    Fix uncompress page data (#161)
    
    * fix uncompress
    
    * modify position
---
 .../java/org/apache/tsfile/read/reader/chunk/ChunkReader.java     | 8 ++++++--
 1 file changed, 6 insertions(+), 2 deletions(-)

diff --git 
a/java/tsfile/src/main/java/org/apache/tsfile/read/reader/chunk/ChunkReader.java
 
b/java/tsfile/src/main/java/org/apache/tsfile/read/reader/chunk/ChunkReader.java
index dc5af465..1b747739 100644
--- 
a/java/tsfile/src/main/java/org/apache/tsfile/read/reader/chunk/ChunkReader.java
+++ 
b/java/tsfile/src/main/java/org/apache/tsfile/read/reader/chunk/ChunkReader.java
@@ -169,7 +169,11 @@ public class ChunkReader extends AbstractChunkReader {
     byte[] uncompressedPageData = new byte[pageHeader.getUncompressedSize()];
     try {
       unCompressor.uncompress(
-          compressedPageData.array(), 0, compressedPageBodyLength, 
uncompressedPageData, 0);
+          compressedPageData.array(),
+          compressedPageData.arrayOffset() + compressedPageData.position(),
+          compressedPageBodyLength,
+          uncompressedPageData,
+          0);
     } catch (Exception e) {
       throw new IOException(
           "Uncompress error! uncompress size: "
@@ -180,7 +184,7 @@ public class ChunkReader extends AbstractChunkReader {
               + pageHeader
               + e.getMessage());
     }
-
+    compressedPageData.position(compressedPageData.position() + 
compressedPageBodyLength);
     return ByteBuffer.wrap(uncompressedPageData);
   }