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 06:44:21 UTC
[iotdb] 01/01: [To rel/1.0][IOTDB-5417] Fix missing hasNext() before next() in TagAggregationOperator
This is an automated email from the ASF dual-hosted git repository.
ericpai pushed a commit to branch bugfix/cp-iotdb-5417
in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit b68466f5d6766e54dfa7217eb0f3c801b631a620
Author: ericpai <er...@hotmail.com>
AuthorDate: Mon Jan 16 14:44:05 2023 +0800
[To rel/1.0][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 cf18c26b74..4cf85411ec 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).hasNext()) {
return false;
}