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);
}