From 2e9c7bce85721bb6f3615001378acb99349ed425 Mon Sep 17 00:00:00 2001 From: Caideyipi <87789683+Caideyipi@users.noreply.github.com> Date: Mon, 22 Jun 2026 14:27:21 +0800 Subject: [PATCH] Fix SingleDeviceViewOperatorTest row assertion --- .../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 f88cdef3e2bc5..f4681cabe8c50 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 @@ -171,16 +171,14 @@ public void 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(); if (tsBlock == null || tsBlock.isEmpty()) { continue; } 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", @@ -201,9 +199,8 @@ public void singleDeviceViewOperatorTest() { assertTrue(tsBlock.getColumn(3).isNull(i)); } } - count++; } - assertEquals(500, total); + assertEquals(500, count); } catch (Exception e) { e.printStackTrace(); fail();