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

Reply via email to