You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by ju...@apache.org on 2026/02/04 09:32:37 UTC
(iotdb) 01/02: fix
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 <87...@users.noreply.github.com>
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