This is an automated email from the ASF dual-hosted git repository. shuwenwei pushed a commit to branch fixLoadSplitTimePartitionWithEmptyChunk-1.3 in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit ad54c386371412d1b793b30106345b736978787f Author: shuwenwei <[email protected]> AuthorDate: Thu Jul 17 17:35:40 2025 +0800 Fix the handling of empty value chunk when load splitting time partitions (#15966) * Fix the handling of empty value chunk when load splitting time partitions * modify test --- .../apache/iotdb/db/storageengine/load/splitter/TsFileSplitter.java | 3 +++ .../dataregion/compaction/BatchedCompactionWithTsFileSplitterTest.java | 2 +- 2 files changed, 4 insertions(+), 1 deletion(-) diff --git a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/load/splitter/TsFileSplitter.java b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/load/splitter/TsFileSplitter.java index 1a16440db8d..46d596a4912 100644 --- a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/load/splitter/TsFileSplitter.java +++ b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/load/splitter/TsFileSplitter.java @@ -530,6 +530,9 @@ public class TsFileSplitter { alignedChunkData.addValueChunk(header); if (!isTimeChunkNeedDecode) { alignedChunkData.writeEntireChunk(ByteBuffer.allocate(0), chunkMetadata); + } else { + alignedChunkData.writeEntirePage( + new PageHeader(0, 0, chunkMetadata.getStatistics()), ByteBuffer.allocate(0)); } allChunkData.add(alignedChunkData); } diff --git a/iotdb-core/datanode/src/test/java/org/apache/iotdb/db/storageengine/dataregion/compaction/BatchedCompactionWithTsFileSplitterTest.java b/iotdb-core/datanode/src/test/java/org/apache/iotdb/db/storageengine/dataregion/compaction/BatchedCompactionWithTsFileSplitterTest.java index 6323d15dcff..37d38411ff6 100644 --- a/iotdb-core/datanode/src/test/java/org/apache/iotdb/db/storageengine/dataregion/compaction/BatchedCompactionWithTsFileSplitterTest.java +++ b/iotdb-core/datanode/src/test/java/org/apache/iotdb/db/storageengine/dataregion/compaction/BatchedCompactionWithTsFileSplitterTest.java @@ -223,7 +223,7 @@ public class BatchedCompactionWithTsFileSplitterTest extends AbstractCompactionT }, TSEncoding.PLAIN, CompressionType.LZ4, - Arrays.asList(false, false, false, false, false), + Arrays.asList(false, false, false, true, false), true); seqResources.add(seqResource2);
