From 0c2c8b5269e8f5c334d980d93e1648e2729f2790 Mon Sep 17 00:00:00 2001
From: Caideyipi <87789683+Caideyipi@users.noreply.github.com>
Date: Thu, 18 Jun 2026 10:33:55 +0800
Subject: [PATCH] Fix double living table schema race in IT

---
 .../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 4d5f350a7c7b5..cd9a1c193fd2c 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 void testBasicDoubleLiving() {
         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 void testBasicDoubleLiving() {
 
     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);