This is an automated email from the ASF dual-hosted git repository.
jiangtian pushed a commit to branch removeTsFIleModule_v4
in repository https://gitbox.apache.org/repos/asf/iotdb.git
The following commit(s) were added to refs/heads/removeTsFIleModule_v4 by this
push:
new 0025cf514b6 fix types
0025cf514b6 is described below
commit 0025cf514b67d1b39077ecb5c9f0db331105d1ac
Author: Tian Jiang <[email protected]>
AuthorDate: Fri Apr 19 18:44:42 2024 +0800
fix types
---
.../org/apache/iotdb/db/pipe/event/common/row/PipeRowCollector.java | 2 +-
.../iotdb/db/storageengine/dataregion/memtable/ReadOnlyMemChunk.java | 2 +-
2 files changed, 2 insertions(+), 2 deletions(-)
diff --git
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/event/common/row/PipeRowCollector.java
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/event/common/row/PipeRowCollector.java
index c2bbe4c22b4..cd8265ea7a1 100644
---
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/event/common/row/PipeRowCollector.java
+++
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/event/common/row/PipeRowCollector.java
@@ -56,7 +56,7 @@ public class PipeRowCollector implements RowCollector {
}
final PipeRow pipeRow = (PipeRow) row;
- final MeasurementSchema[] measurementSchemaArray =
pipeRow.getMeasurementSchemaList();
+ final IMeasurementSchema[] measurementSchemaArray =
pipeRow.getMeasurementSchemaList();
// Trigger collection when a PipeResetTabletRow is encountered
if (row instanceof PipeResetTabletRow) {
diff --git
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/memtable/ReadOnlyMemChunk.java
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/memtable/ReadOnlyMemChunk.java
index b967c61b7f6..0f96510f737 100644
---
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/memtable/ReadOnlyMemChunk.java
+++
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/memtable/ReadOnlyMemChunk.java
@@ -98,7 +98,7 @@ public class ReadOnlyMemChunk {
private void initChunkMetaFromTsBlock() throws QueryProcessException {
Statistics statsByType = Statistics.getStatsByType(dataType);
- IChunkMetadata metaData = new ChunkMetadata(measurementUid, dataType, 0,
statsByType);
+ IChunkMetadata metaData = new ChunkMetadata(measurementUid, dataType,
null, null, 0, statsByType);
if (!isEmpty()) {
switch (dataType) {
case BOOLEAN:
