(iotdb) branch master updated: using correct encoding in read chunk compaction (#15250)

[jiangtian]

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

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


The following commit(s) were added to refs/heads/master by this push:
     new 5ddd4234666 using correct encoding in read chunk compaction (#15250)
5ddd4234666 is described below

commit 5ddd4234666da864e97f65f3f967e1c7fff27b30
Author: shuwenwei <55970239+shuwen...@users.noreply.github.com>
AuthorDate: Wed Apr 2 10:28:39 2025 +0800

    using correct encoding in read chunk compaction (#15250)
    
    * using correct encoding in read chunk compaction
    
    * add ut
    
    * modify data type
---
 .../executor/readchunk/ReadChunkAlignedSeriesCompactionExecutor.java | 5 ++---
 .../inner/BatchedAlignedSeriesReadChunkCompactionTest.java           | 2 +-
 2 files changed, 3 insertions(+), 4 deletions(-)

diff --git 
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/compaction/execute/utils/executor/readchunk/ReadChunkAlignedSeriesCompactionExecutor.java
 
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/compaction/execute/utils/executor/readchunk/ReadChunkAlignedSeriesCompactionExecutor.java
index f18d8383e48..e6891199bb4 100644
--- 
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/compaction/execute/utils/executor/readchunk/ReadChunkAlignedSeriesCompactionExecutor.java
+++ 
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/compaction/execute/utils/executor/readchunk/ReadChunkAlignedSeriesCompactionExecutor.java
@@ -385,9 +385,8 @@ public class ReadChunkAlignedSeriesCompactionExecutor {
             new ValuePageReader(
                 valuePage.getHeader(),
                 valuePage.getUnCompressedData(),
-                schemaList.get(i).getType(),
-                Decoder.getDecoderByType(
-                    schemaList.get(i).getEncodingType(), 
schemaList.get(i).getType()));
+                valuePage.getDataType(),
+                Decoder.getDecoderByType(valuePage.getEncoding(), 
valuePage.getDataType()));
         
valuePageReader.setDeleteIntervalList(valuePage.getDeleteIntervalList());
         nonEmptyPageNum++;
       }
diff --git 
a/iotdb-core/datanode/src/test/java/org/apache/iotdb/db/storageengine/dataregion/compaction/inner/BatchedAlignedSeriesReadChunkCompactionTest.java
 
b/iotdb-core/datanode/src/test/java/org/apache/iotdb/db/storageengine/dataregion/compaction/inner/BatchedAlignedSeriesReadChunkCompactionTest.java
index a73be5ca37c..97fc553b45d 100644
--- 
a/iotdb-core/datanode/src/test/java/org/apache/iotdb/db/storageengine/dataregion/compaction/inner/BatchedAlignedSeriesReadChunkCompactionTest.java
+++ 
b/iotdb-core/datanode/src/test/java/org/apache/iotdb/db/storageengine/dataregion/compaction/inner/BatchedAlignedSeriesReadChunkCompactionTest.java
@@ -561,7 +561,7 @@ public class BatchedAlignedSeriesReadChunkCompactionTest 
extends AbstractCompact
             "d0",
             Arrays.asList("s0", "s1", "s2"),
             new TimeRange[] {new TimeRange(100000, 200000), new 
TimeRange(300000, 500000)},
-            TSEncoding.PLAIN,
+            TSEncoding.RLE,
             CompressionType.LZ4,
             Arrays.asList(false, false, false),
             true);