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 788de1882cd Stabilize bidirectional pipe template conflict IT (#19016)
788de1882cd is described below
commit 788de1882cd21336b81ca4451b90f9289d9cfc25
Author: Caideyipi <[email protected]>
AuthorDate: Tue Oct 27 11:41:37 2026 +0800
Stabilize bidirectional pipe template conflict IT (#19016)
---
.../treemodel/auto/enhanced/IoTDBPipeAutoConflictIT.java | 15 ++++++++++++++-
1 file changed, 14 insertions(+), 1 deletion(-)
diff --git
a/integration-test/src/test/java/org/apache/iotdb/pipe/it/dual/treemodel/auto/enhanced/IoTDBPipeAutoConflictIT.java
b/integration-test/src/test/java/org/apache/iotdb/pipe/it/dual/treemodel/auto/enhanced/IoTDBPipeAutoConflictIT.java
index 8562194be99..5cc8bc5d741 100644
---
a/integration-test/src/test/java/org/apache/iotdb/pipe/it/dual/treemodel/auto/enhanced/IoTDBPipeAutoConflictIT.java
+++
b/integration-test/src/test/java/org/apache/iotdb/pipe/it/dual/treemodel/auto/enhanced/IoTDBPipeAutoConflictIT.java
@@ -311,6 +311,14 @@ public class IoTDBPipeAutoConflictIT extends
AbstractPipeDualTreeModelAutoIT {
"set device template t1 to root.db"),
null);
+ // Prevent receiver writes from creating ordinary timeseries before the
template binding
+ // arrives.
+ TestUtils.assertDataEventuallyOnEnv(
+ receiverEnv,
+ "show paths set device template t1",
+ "Paths,",
+ Collections.singleton("root.db,"));
+
try (Connection connection = senderEnv.getConnection()) {
for (int i = 0; i < 200; ++i) {
TestUtils.executeNonQuery(
@@ -320,8 +328,13 @@ public class IoTDBPipeAutoConflictIT extends
AbstractPipeDualTreeModelAutoIT {
}
}
+ // SHOW PATHS can expose a pre-set binding before the DataNodes can use
the template.
+ // Retry the first idempotent write until the receiver can activate and
extend the template.
+ TestUtils.executeNonQueryWithRetry(
+ receiverEnv, "insert into root.db.d1(time, s1) values (200, 1)");
+
try (Connection connection = receiverEnv.getConnection()) {
- for (int i = 200; i < 400; ++i) {
+ for (int i = 201; i < 400; ++i) {
TestUtils.executeNonQuery(
receiverEnv,
String.format("insert into root.db.d1(time, s1) values (%s, 1)",
i),
