You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by ja...@apache.org on 2022/11/27 03:16:11 UTC
[iotdb] 02/03: fix it
This is an automated email from the ASF dual-hosted git repository.
jackietien pushed a commit to branch IOTDB-5050
in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit bdce979954235f05d930da990246d3962bef863c
Author: JackieTien97 <ja...@gmail.com>
AuthorDate: Sat Nov 26 20:26:36 2022 +0800
fix it
---
.../db/mpp/execution/operator/source/AlignedSeriesScanOperator.java | 2 ++
.../iotdb/db/mpp/execution/operator/source/SeriesScanOperator.java | 1 +
2 files changed, 3 insertions(+)
diff --git a/server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/source/AlignedSeriesScanOperator.java b/server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/source/AlignedSeriesScanOperator.java
index 8eb1d44925..f4b67be984 100644
--- a/server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/source/AlignedSeriesScanOperator.java
+++ b/server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/source/AlignedSeriesScanOperator.java
@@ -179,6 +179,8 @@ public class AlignedSeriesScanOperator implements DataSourceOperator {
TimeColumn timeColumn = tsBlock.getTimeColumn();
for (int i = 0; i < size; i++) {
timeColumnBuilder.writeLong(timeColumn.getLong(i));
+ builder.declarePosition();
+ ;
}
for (int columnIndex = 0, columnSize = tsBlock.getValueColumnCount();
columnIndex < columnSize;
diff --git a/server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/source/SeriesScanOperator.java b/server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/source/SeriesScanOperator.java
index d20ea48b2d..308fcfcb13 100644
--- a/server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/source/SeriesScanOperator.java
+++ b/server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/source/SeriesScanOperator.java
@@ -184,6 +184,7 @@ public class SeriesScanOperator implements DataSourceOperator {
for (int i = 0, size = tsBlock.getPositionCount(); i < size; i++) {
timeColumnBuilder.writeLong(timeColumn.getLong(i));
columnBuilder.write(column, i);
+ builder.declarePosition();
}
}