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