This is an automated email from the ASF dual-hosted git repository. rong pushed a commit to branch trasnsform-operator-bugfix in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit 6b3fabfd29d1711d6c77617b6ba2171e88d72bc3 Author: Steve Yurong Su <[email protected]> AuthorDate: Mon May 16 11:59:33 2022 +0800 invoke declarePositions(rowCount) in Operator#next() --- .../apache/iotdb/db/mpp/execution/operator/process/FilterOperator.java | 2 ++ .../iotdb/db/mpp/execution/operator/process/TransformOperator.java | 2 ++ 2 files changed, 4 insertions(+) diff --git a/server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/process/FilterOperator.java b/server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/process/FilterOperator.java index 23199ffd84..f6a7122fb9 100644 --- a/server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/process/FilterOperator.java +++ b/server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/process/FilterOperator.java @@ -141,6 +141,8 @@ public class FilterOperator extends TransformOperator { inputLayer.updateRowRecordListEvictionUpperBound(); } + + tsBlockBuilder.declarePositions(rowCount); } catch (Exception e) { throw new RuntimeException(e); } diff --git a/server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/process/TransformOperator.java b/server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/process/TransformOperator.java index 7a99fae9bf..69acb3a9a3 100644 --- a/server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/process/TransformOperator.java +++ b/server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/process/TransformOperator.java @@ -195,6 +195,8 @@ public class TransformOperator implements ProcessOperator { inputLayer.updateRowRecordListEvictionUpperBound(); } + + tsBlockBuilder.declarePositions(rowCount); } catch (Exception e) { throw new RuntimeException(e); }
