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 f49370013af Fix config event race in pipe idempotent table IT (#18403)
f49370013af is described below
commit f49370013af232e2becda4460b6609f62b690bdd
Author: Caideyipi <[email protected]>
AuthorDate: Wed Aug 5 16:57:56 2026 +0800
Fix config event race in pipe idempotent table IT (#18403)
---
.../it/dual/tablemodel/manual/enhanced/IoTDBPipeIdempotentIT.java | 7 ++++++-
1 file changed, 6 insertions(+), 1 deletion(-)
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 9094810670c..170ef173565 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
@@ -257,6 +257,11 @@ public class IoTDBPipeIdempotentIT extends
AbstractPipeTableModelDualManualIT {
TestUtils.executeNonQueries(
database, BaseEnv.TABLE_SQL_DIALECT, senderEnv, beforeSqlList, null);
+ // Pipe transfers config events in order. Use a database event as a
progress marker to ensure
+ // that all preparation statements have been applied on receiverEnv.
+ TableModelUtils.createDatabase(senderEnv, "test1");
+ TableModelUtils.hasDataBase("test1", receiverEnv);
+
TestUtils.executeNonQuery(database, BaseEnv.TABLE_SQL_DIALECT,
receiverEnv, testSql, null);
// Create an idempotent conflict
@@ -265,6 +270,6 @@ public class IoTDBPipeIdempotentIT extends
AbstractPipeTableModelDualManualIT {
TableModelUtils.createDatabase(senderEnv, "test2");
// Assume that the "database" is executed on receiverEnv
- TestUtils.assertDataSizeEventuallyOnEnv(receiverEnv, "show databases", 3,
null);
+ TestUtils.assertDataSizeEventuallyOnEnv(receiverEnv, "show databases", 4,
null);
}
}
