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

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

commit 533f0af6404d4c07cbd38d2d804f8c5e344df806
Author: Caideyipi <[email protected]>
AuthorDate: Wed Feb 4 09:44:36 2026 +0800

    fix
---
 .../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 13d95eadeb1..16a4dd168b1 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
@@ -444,7 +444,11 @@ public class TsFileInsertionEventScanParser extends 
TsFileInsertionEventParser {
                           tsFileSequenceReader.readChunk(-1, 
chunkHeader.getDataSize())));
           currentIsAligned = false;
           currentMeasurements.add(
-              new MeasurementSchema(chunkHeader.getMeasurementID(), 
chunkHeader.getDataType()));
+              new MeasurementSchema(
+                  chunkHeader.getMeasurementID(),
+                  chunkHeader.getDataType(),
+                  chunkHeader.getEncodingType(),
+                  chunkHeader.getCompressionType()));
           return;
         case MetaMarker.VALUE_CHUNK_HEADER:
         case MetaMarker.ONLY_ONE_PAGE_VALUE_CHUNK_HEADER:
@@ -506,7 +510,11 @@ public class TsFileInsertionEventScanParser extends 
TsFileInsertionEventParser {
               new Chunk(
                   chunkHeader, tsFileSequenceReader.readChunk(-1, 
chunkHeader.getDataSize())));
           currentMeasurements.add(
-              new MeasurementSchema(chunkHeader.getMeasurementID(), 
chunkHeader.getDataType()));
+              new MeasurementSchema(
+                  chunkHeader.getMeasurementID(),
+                  chunkHeader.getDataType(),
+                  chunkHeader.getEncodingType(),
+                  chunkHeader.getCompressionType()));
           break;
         case MetaMarker.CHUNK_GROUP_HEADER:
           // Return before "currentDevice" changes

Reply via email to