[iotdb] branch master updated: [IOTDB-5417] Fix missing hasNext() before next() in TagAggregationOperator

[ja...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

jackietien pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/iotdb.git


The following commit(s) were added to refs/heads/master by this push:
     new 5ee9541dae [IOTDB-5417] Fix missing hasNext() before next() in TagAggregationOperator
5ee9541dae is described below

commit 5ee9541daef9cd6cce9993512db4daf014243fd3
Author: BaiJian <er...@hotmail.com>
AuthorDate: Mon Jan 16 14:32:08 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;
       }