You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by ji...@apache.org on 2025/04/02 02:28:45 UTC
(iotdb) branch master updated: using correct encoding in read chunk compaction (#15250)
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 <55...@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);