This is an automated email from the ASF dual-hosted git repository.

jackietien pushed a commit to branch rc/2.0.8
in repository https://gitbox.apache.org/repos/asf/iotdb.git

commit be9150300db6c3782f373eef167db0072740527b
Author: Zhenyu Luo <[email protected]>
AuthorDate: Thu Feb 5 12:28:34 2026 +0800

    fix: Fix missing encoding and compression information for Measurement 
(#17141)
---
 .../tsfile/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 99d35f7eb98..5dc6228f1d1 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
@@ -512,7 +512,11 @@ public class TsFileInsertionEventScanParser extends 
TsFileInsertionEventParser {
                     : 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,
@@ -582,7 +586,11 @@ public class TsFileInsertionEventScanParser extends 
TsFileInsertionEventParser {
             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,

Reply via email to