This is an automated email from the ASF dual-hosted git repository.

shuwenwei pushed a commit to branch fixMemTableQueryBug-1.3
in repository https://gitbox.apache.org/repos/asf/iotdb.git

commit b6c895a55a59548e31f6e940c39b794402a4353a
Author: shuwenwei <[email protected]>
AuthorDate: Tue Dec 30 15:25:42 2025 +0800

    fix conflict
---
 .../test/java/org/apache/iotdb/db/it/IoTDBFlushQueryIT.java    | 10 +++++-----
 1 file changed, 5 insertions(+), 5 deletions(-)

diff --git 
a/integration-test/src/test/java/org/apache/iotdb/db/it/IoTDBFlushQueryIT.java 
b/integration-test/src/test/java/org/apache/iotdb/db/it/IoTDBFlushQueryIT.java
index 896f23248c5..ba6f4fc272f 100644
--- 
a/integration-test/src/test/java/org/apache/iotdb/db/it/IoTDBFlushQueryIT.java
+++ 
b/integration-test/src/test/java/org/apache/iotdb/db/it/IoTDBFlushQueryIT.java
@@ -30,7 +30,6 @@ import org.apache.iotdb.rpc.StatementExecutionException;
 
 import org.apache.tsfile.enums.TSDataType;
 import org.apache.tsfile.write.record.Tablet;
-import org.apache.tsfile.write.schema.IMeasurementSchema;
 import org.apache.tsfile.write.schema.MeasurementSchema;
 import org.junit.AfterClass;
 import org.junit.Assert;
@@ -249,20 +248,21 @@ public class IoTDBFlushQueryIT {
   private static void generateTimeRangeWithTimestamp(
       ISession session, String device, long start, long end)
       throws IoTDBConnectionException, StatementExecutionException {
-    List<IMeasurementSchema> measurementSchemas =
+    List<MeasurementSchema> measurementSchemas =
         Collections.singletonList(new MeasurementSchema("s1", 
TSDataType.INT64));
     Tablet tablet = new Tablet(device, measurementSchemas);
     for (long currentTime = start; currentTime <= end; currentTime++) {
-      int rowIndex = tablet.getRowSize();
+      int rowIndex = tablet.rowSize;
       if (rowIndex == tablet.getMaxRowNumber()) {
         session.insertTablet(tablet);
         tablet.reset();
         rowIndex = 0;
       }
       tablet.addTimestamp(rowIndex, currentTime);
-      tablet.addValue(rowIndex, 0, currentTime);
+      tablet.addValue("s1", 0, currentTime);
+      tablet.rowSize++;
     }
-    if (tablet.getRowSize() > 0) {
+    if (tablet.rowSize > 0) {
       session.insertTablet(tablet);
     }
   }

Reply via email to