You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by er...@apache.org on 2023/01/16 04:24:32 UTC
[iotdb] branch bugfix/iotdb-5417 created (now 3c73f0dd31)
This is an automated email from the ASF dual-hosted git repository.
ericpai pushed a change to branch bugfix/iotdb-5417
in repository https://gitbox.apache.org/repos/asf/iotdb.git
at 3c73f0dd31 [IOTDB-5417] Fix missing hasNext() before next() in TagAggregationOperator
This branch includes the following new commits:
new 3c73f0dd31 [IOTDB-5417] Fix missing hasNext() before next() in TagAggregationOperator
The 1 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
[iotdb] 01/01: [IOTDB-5417] Fix missing hasNext() before next() in TagAggregationOperator
Posted by er...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
ericpai pushed a commit to branch bugfix/iotdb-5417
in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit 3c73f0dd313c6ac735541afb361b39253cfb338a
Author: ericpai <er...@hotmail.com>
AuthorDate: Mon Jan 16 12:24:16 2023 +0800
[IOTDB-5417] Fix missing hasNext() before next() in TagAggregationOperator
---
.../iotdb/db/mpp/execution/operator/process/TagAggregationOperator.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/process/TagAggregationOperator.java b/server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/process/TagAggregationOperator.java
index 778e0d28c5..1e2d5850ce 100644
--- a/server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/process/TagAggregationOperator.java
+++ b/server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/process/TagAggregationOperator.java
@@ -122,7 +122,7 @@ public class TagAggregationOperator implements ProcessOperator {
continue;
}
- if (!canCallNext[i]) {
+ if (!canCallNext[i] || !children.get(i).hasNextWithTimer()) {
return false;
}