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

zhihao pushed a commit to branch fix/szh/window_partition_bug
in repository https://gitbox.apache.org/repos/asf/iotdb.git


The following commit(s) were added to refs/heads/fix/szh/window_partition_bug 
by this push:
     new 13ba08a6122 MVN spotless apply again and again.
13ba08a6122 is described below

commit 13ba08a6122ea95b8c566fe22e5d4393a2a2eada
Author: Sh-Zh-7 <[email protected]>
AuthorDate: Wed Nov 26 10:26:00 2025 +0800

    MVN spotless apply again and again.
---
 .../execution/operator/process/window/TableWindowOperator.java        | 4 +++-
 1 file changed, 3 insertions(+), 1 deletion(-)

diff --git 
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/process/window/TableWindowOperator.java
 
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/process/window/TableWindowOperator.java
index b074ae93c42..ba5f5358167 100644
--- 
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/process/window/TableWindowOperator.java
+++ 
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/process/window/TableWindowOperator.java
@@ -318,7 +318,9 @@ public class TableWindowOperator implements ProcessOperator 
{
       // Reset window functions for new partition
       partitionExecutor.resetWindowFunctions();
 
-      while (!tsBlockBuilder.isFull() && partitionExecutor.hasNext()) {
+      while (System.nanoTime() - startTime < maxRuntime
+          && !tsBlockBuilder.isFull()
+          && partitionExecutor.hasNext()) {
         partitionExecutor.processNextRow(tsBlockBuilder);
       }
 

Reply via email to