From b372fd1381115f3d339a45d8c52e373cd1a2a52f Mon Sep 17 00:00:00 2001 From: shuwenwei Date: Thu, 29 Jan 2026 10:05:42 +0800 Subject: [PATCH] fix rewrite non aligned chunk --- .../src/main/java/org/apache/tsfile/read/common/Chunk.java | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/java/tsfile/src/main/java/org/apache/tsfile/read/common/Chunk.java b/java/tsfile/src/main/java/org/apache/tsfile/read/common/Chunk.java index 5d8eaf13d..01937c743 100644 --- a/java/tsfile/src/main/java/org/apache/tsfile/read/common/Chunk.java +++ b/java/tsfile/src/main/java/org/apache/tsfile/read/common/Chunk.java @@ -369,7 +369,9 @@ public Chunk rewrite(TSDataType newType) throws IOException { ByteBuffer newChunkData = chunkWriter.getByteBuffer(); ChunkHeader newChunkHeader = new ChunkHeader( - chunkHeader.getChunkType(), + chunkWriter.getNumOfPages() > 1 + ? MetaMarker.CHUNK_HEADER + : MetaMarker.ONLY_ONE_PAGE_CHUNK_HEADER, chunkHeader.getMeasurementID(), newChunkData.capacity(), newType,