From eb02d2554e5e22fd2029c674fda8f4d92d85fd32 Mon Sep 17 00:00:00 2001
From: Caideyipi <87789683+Caideyipi@users.noreply.github.com>
Date: Mon, 22 Jun 2026 17:32:14 +0800
Subject: [PATCH] Fix SingleDeviceViewOperatorTest row assertion (#17995)

---
 .../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 a0b9475933339..22fedb8b0bd64 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 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();
         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 void singleDeviceViewOperatorTest() {
             assertTrue(tsBlock.getColumn(3).isNull(i));
           }
         }
-        count++;
       }
-      assertEquals(500, total);
+      assertEquals(500, count);
     } catch (Exception e) {
       e.printStackTrace();
       fail();