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 913104e741e Fix flaky pipe idempotent table IT (#18316)
913104e741e is described below

commit 913104e741e6a477bc63bd692ca12bc8152d6d42
Author: Caideyipi <[email protected]>
AuthorDate: Tue Jul 28 10:45:43 2026 +0800

    Fix flaky pipe idempotent table IT (#18316)
---
 .../pipe/it/dual/tablemodel/manual/enhanced/IoTDBPipeIdempotentIT.java | 3 +++
 1 file changed, 3 insertions(+)

diff --git 
a/integration-test/src/test/java/org/apache/iotdb/pipe/it/dual/tablemodel/manual/enhanced/IoTDBPipeIdempotentIT.java
 
b/integration-test/src/test/java/org/apache/iotdb/pipe/it/dual/tablemodel/manual/enhanced/IoTDBPipeIdempotentIT.java
index e56e0e9e47b..9094810670c 100644
--- 
a/integration-test/src/test/java/org/apache/iotdb/pipe/it/dual/tablemodel/manual/enhanced/IoTDBPipeIdempotentIT.java
+++ 
b/integration-test/src/test/java/org/apache/iotdb/pipe/it/dual/tablemodel/manual/enhanced/IoTDBPipeIdempotentIT.java
@@ -251,6 +251,9 @@ public class IoTDBPipeIdempotentIT extends 
AbstractPipeTableModelDualManualIT {
       Assert.assertEquals(TSStatusCode.SUCCESS_STATUS.getStatusCode(), 
status.getCode());
     }
 
+    // Pipe creation does not wait for the historical database snapshot to be 
applied.
+    TableModelUtils.hasDataBase(database, receiverEnv);
+
     TestUtils.executeNonQueries(
         database, BaseEnv.TABLE_SQL_DIALECT, senderEnv, beforeSqlList, null);
 

Reply via email to