You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by ro...@apache.org on 2022/05/16 04:17:10 UTC
[iotdb] 03/08: fix FilterOperator#iterateFilterReaderToNextValid()
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 <ro...@apache.org>
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