(iotdb) branch master updated: Fix double living table schema race in IT (#17980)

[jiangtian]

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

jt2594838 pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/iotdb.git


The following commit(s) were added to refs/heads/master by this push:
     new 67c69b46589 Fix double living table schema race in IT (#17980)
67c69b46589 is described below

commit 67c69b46589307afc4f51c21260277751fad5332
Author: Caideyipi <87789683+caidey...@users.noreply.github.com>
AuthorDate: Mon Jun 22 09:25:08 2026 +0800

    Fix double living table schema race in IT (#17980)
---
 .../dual/tablemodel/manual/enhanced/IoTDBPipeDoubleLivingIT.java  | 8 ++++++++
 1 file changed, 8 insertions(+)

diff --git 
a/integration-test/src/test/java/org/apache/iotdb/pipe/it/dual/tablemodel/manual/enhanced/IoTDBPipeDoubleLivingIT.java
 
b/integration-test/src/test/java/org/apache/iotdb/pipe/it/dual/tablemodel/manual/enhanced/IoTDBPipeDoubleLivingIT.java
index 4d5f350a7c7..cd9a1c193fd 100644
--- 
a/integration-test/src/test/java/org/apache/iotdb/pipe/it/dual/tablemodel/manual/enhanced/IoTDBPipeDoubleLivingIT.java
+++ 
b/integration-test/src/test/java/org/apache/iotdb/pipe/it/dual/tablemodel/manual/enhanced/IoTDBPipeDoubleLivingIT.java
@@ -173,6 +173,12 @@ public class IoTDBPipeDoubleLivingIT extends 
AbstractPipeTableModelDualManualIT
         TestUtils.executeNonQuery(
             senderEnv, String.format("insert into root.db.d1(time, s1) values 
(%s, 1)", i), conn);
       }
+    } catch (SQLException e) {
+      throw new RuntimeException(e);
+    }
+
+    try (Connection conn = receiverEnv.getConnection()) {
+      // insertion on receiver
       for (int i = 200; i < 300; ++i) {
         TestUtils.executeNonQuery(
             receiverEnv, String.format("insert into root.db.d1(time, s1) 
values (%s, 1)", i), conn);
@@ -183,6 +189,8 @@ public class IoTDBPipeDoubleLivingIT extends 
AbstractPipeTableModelDualManualIT
 
     TableModelUtils.insertData("test", "test", 100, 200, senderEnv);
 
+    TableModelUtils.assertData("test", "test", 0, 200, receiverEnv, 
handleFailure);
+
     TableModelUtils.insertData("test", "test", 200, 300, receiverEnv);
 
     TestUtils.executeNonQuery(senderEnv, "flush", null);