Skip to content

Commit 5ddd423

Browse files
authored
using correct encoding in read chunk compaction (apache#15250)
* using correct encoding in read chunk compaction * add ut * modify data type
1 parent 91d067b commit 5ddd423

File tree

2 files changed

+3
-4
lines changed

2 files changed

+3
-4
lines changed

iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/compaction/execute/utils/executor/readchunk/ReadChunkAlignedSeriesCompactionExecutor.java

Lines changed: 2 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -385,9 +385,8 @@ private void compactAlignedPageByDeserialize(PageLoader timePage, List<PageLoade
385385
new ValuePageReader(
386386
valuePage.getHeader(),
387387
valuePage.getUnCompressedData(),
388-
schemaList.get(i).getType(),
389-
Decoder.getDecoderByType(
390-
schemaList.get(i).getEncodingType(), schemaList.get(i).getType()));
388+
valuePage.getDataType(),
389+
Decoder.getDecoderByType(valuePage.getEncoding(), valuePage.getDataType()));
391390
valuePageReader.setDeleteIntervalList(valuePage.getDeleteIntervalList());
392391
nonEmptyPageNum++;
393392
}

iotdb-core/datanode/src/test/java/org/apache/iotdb/db/storageengine/dataregion/compaction/inner/BatchedAlignedSeriesReadChunkCompactionTest.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -561,7 +561,7 @@ public void testCompactionWithDifferentCompressionTypeOrEncoding() throws Except
561561
"d0",
562562
Arrays.asList("s0", "s1", "s2"),
563563
new TimeRange[] {new TimeRange(100000, 200000), new TimeRange(300000, 500000)},
564-
TSEncoding.PLAIN,
564+
TSEncoding.RLE,
565565
CompressionType.LZ4,
566566
Arrays.asList(false, false, false),
567567
true);

0 commit comments

Comments
 (0)