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