You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by zh...@apache.org on 2025/11/26 02:23:06 UTC
(iotdb) 03/04: MVN spotless apply.
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
commit 965767553d8a39255713eda23555080306f32c5e
Author: Sh-Zh-7 <zh...@qq.com>
AuthorDate: Wed Nov 26 09:50:16 2025 +0800
MVN spotless apply.
---
.../process/window/TableWindowOperatorTest.java | 20 ++++++++++----------
1 file changed, 10 insertions(+), 10 deletions(-)
diff --git a/iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/execution/operator/process/window/TableWindowOperatorTest.java b/iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/execution/operator/process/window/TableWindowOperatorTest.java
index b444c4bfb62..4258470a0ba 100644
--- a/iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/execution/operator/process/window/TableWindowOperatorTest.java
+++ b/iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/execution/operator/process/window/TableWindowOperatorTest.java
@@ -196,21 +196,21 @@ public class TableWindowOperatorTest {
public void testMixedPartition2() {
long[][] timeArray =
new long[][] {
- {1, 2, 3},
- {4, 5},
- {6},
+ {1, 2, 3},
+ {4, 5},
+ {6},
};
String[][] deviceIdArray =
new String[][] {
- {"d1", "d1", "d2"},
- {"d2", "d3"},
- {"d3"},
+ {"d1", "d1", "d2"},
+ {"d2", "d3"},
+ {"d3"},
};
int[][] valueArray =
new int[][] {
- {1, 2, 3},
- {4, 5},
- {6},
+ {1, 2, 3},
+ {4, 5},
+ {6},
};
long[] expectColumn1 = new long[] {1, 2, 3, 4, 5, 6};
@@ -220,7 +220,7 @@ public class TableWindowOperatorTest {
int count = 0;
try (TableWindowOperator windowOperator =
- genWindowOperator(timeArray, deviceIdArray, valueArray)) {
+ genWindowOperator(timeArray, deviceIdArray, valueArray)) {
ListenableFuture<?> listenableFuture = windowOperator.isBlocked();
listenableFuture.get();
while (!windowOperator.isFinished() && windowOperator.hasNext()) {