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 53b4c0f0e3b5a39688495a4e938bf5a1fa4c4b2a Author: Steve Yurong Su <[email protected]> AuthorDate: Mon May 16 11:58:34 2022 +0800 fix FilterOperator#iterateFilterReaderToNextValid() --- .../iotdb/db/mpp/execution/operator/process/FilterOperator.java | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) 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 f9eafceb03..23199ffd84 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 @@ -94,10 +94,10 @@ public class FilterOperator extends TransformOperator { } private void iterateFilterReaderToNextValid() throws QueryProcessException, IOException { - while (filterPointReader.next() - && (filterPointReader.isCurrentNull() || !filterPointReader.currentBoolean())) { + do { filterPointReader.readyForNext(); - } + } while (filterPointReader.next() + && (filterPointReader.isCurrentNull() || !filterPointReader.currentBoolean())); } @Override
