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

Reply via email to