This is an automated email from the ASF dual-hosted git repository.
jt2594838 pushed a commit to branch dev/1.3
in repository https://gitbox.apache.org/repos/asf/iotdb.git
The following commit(s) were added to refs/heads/dev/1.3 by this push:
new 9e383898899 Fix SingleDeviceViewOperatorTest row assertion (#17995)
(#18003)
9e383898899 is described below
commit 9e3838988991c4063a3a8ee0d43d91d306454284
Author: Caideyipi <[email protected]>
AuthorDate: Tue Jun 23 16:10:22 2026 +0800
Fix SingleDeviceViewOperatorTest row assertion (#17995) (#18003)
---
.../execution/operator/SingleDeviceViewOperatorTest.java | 9 +++------
1 file changed, 3 insertions(+), 6 deletions(-)
diff --git
a/iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/execution/operator/SingleDeviceViewOperatorTest.java
b/iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/execution/operator/SingleDeviceViewOperatorTest.java
index a0b94759333..22fedb8b0bd 100644
---
a/iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/execution/operator/SingleDeviceViewOperatorTest.java
+++
b/iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/execution/operator/SingleDeviceViewOperatorTest.java
@@ -165,13 +165,11 @@ public class SingleDeviceViewOperatorTest {
Arrays.asList(1, 2),
Arrays.asList(TSDataType.TEXT, TSDataType.INT32,
TSDataType.INT32, TSDataType.INT32));
int count = 0;
- int total = 0;
while (singleDeviceViewOperator.isBlocked().isDone() &&
singleDeviceViewOperator.hasNext()) {
TsBlock tsBlock = singleDeviceViewOperator.next();
assertEquals(4, tsBlock.getValueColumnCount());
- total += tsBlock.getPositionCount();
- for (int i = 0; i < tsBlock.getPositionCount(); i++) {
- long expectedTime = i + 20L * (count % 25);
+ for (int i = 0; i < tsBlock.getPositionCount(); i++, count++) {
+ long expectedTime = count;
assertEquals(expectedTime, tsBlock.getTimeByIndex(i));
assertEquals(
SINGLE_DEVICE_MERGE_OPERATOR_TEST_SG + ".device0",
@@ -192,9 +190,8 @@ public class SingleDeviceViewOperatorTest {
assertTrue(tsBlock.getColumn(3).isNull(i));
}
}
- count++;
}
- assertEquals(500, total);
+ assertEquals(500, count);
} catch (Exception e) {
e.printStackTrace();
fail();