Skip to content

Commit 8b4c0db

Browse files
authored
fix rewrite non aligned chunk (#713)
1 parent 58c9262 commit 8b4c0db

1 file changed

Lines changed: 3 additions & 1 deletion

File tree

  • java/tsfile/src/main/java/org/apache/tsfile/read/common

java/tsfile/src/main/java/org/apache/tsfile/read/common/Chunk.java

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -369,7 +369,9 @@ public Chunk rewrite(TSDataType newType) throws IOException {
369369
ByteBuffer newChunkData = chunkWriter.getByteBuffer();
370370
ChunkHeader newChunkHeader =
371371
new ChunkHeader(
372-
chunkHeader.getChunkType(),
372+
chunkWriter.getNumOfPages() > 1
373+
? MetaMarker.CHUNK_HEADER
374+
: MetaMarker.ONLY_ONE_PAGE_CHUNK_HEADER,
373375
chunkHeader.getMeasurementID(),
374376
newChunkData.capacity(),
375377
newType,

0 commit comments

Comments
 (0)