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