From c4b6ef7a8221f2435c38e54a156a647c0bb0021f Mon Sep 17 00:00:00 2001 From: luoluoyuyu Date: Mon, 2 Feb 2026 18:05:59 +0800 Subject: [PATCH] fix: Fix missing encoding and compression information for Measurement --- .../parser/scan/TsFileInsertionEventScanParser.java | 12 ++++++++++-- 1 file changed, 10 insertions(+), 2 deletions(-) diff --git a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/event/common/tsfile/parser/scan/TsFileInsertionEventScanParser.java b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/event/common/tsfile/parser/scan/TsFileInsertionEventScanParser.java index 5c9985fe748b7..8be2f93423533 100644 --- a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/event/common/tsfile/parser/scan/TsFileInsertionEventScanParser.java +++ b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/event/common/tsfile/parser/scan/TsFileInsertionEventScanParser.java @@ -507,7 +507,11 @@ private void moveToNextChunkReader() : new SinglePageWholeChunkReader(chunk); currentIsAligned = false; currentMeasurements.add( - new MeasurementSchema(chunkHeader.getMeasurementID(), chunkHeader.getDataType())); + new MeasurementSchema( + chunkHeader.getMeasurementID(), + chunkHeader.getDataType(), + chunkHeader.getEncodingType(), + chunkHeader.getCompressionType())); modsInfos.addAll( ModsOperationUtil.initializeMeasurementMods( currentDevice, @@ -577,7 +581,11 @@ private void moveToNextChunkReader() valueChunkSize += chunkHeader.getDataSize(); valueChunkList.add(chunk); currentMeasurements.add( - new MeasurementSchema(chunkHeader.getMeasurementID(), chunkHeader.getDataType())); + new MeasurementSchema( + chunkHeader.getMeasurementID(), + chunkHeader.getDataType(), + chunkHeader.getEncodingType(), + chunkHeader.getCompressionType())); modsInfos.addAll( ModsOperationUtil.initializeMeasurementMods( currentDevice,