This is an automated email from the ASF dual-hosted git repository.
Caideyipi pushed a commit to branch opc-fix-master
in repository https://gitbox.apache.org/repos/asf/iotdb.git
The following commit(s) were added to refs/heads/opc-fix-master by this push:
new b1e2a2fa82e if
b1e2a2fa82e is described below
commit b1e2a2fa82e610bcba3c31af64b071d75bd85dee
Author: Caideyipi <[email protected]>
AuthorDate: Mon Apr 20 19:06:02 2026 +0800
if
---
.../iotdb/pipe/it/dual/treemodel/auto/basic/IoTDBPipeAutoSplitIT.java | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
diff --git
a/integration-test/src/test/java/org/apache/iotdb/pipe/it/dual/treemodel/auto/basic/IoTDBPipeAutoSplitIT.java
b/integration-test/src/test/java/org/apache/iotdb/pipe/it/dual/treemodel/auto/basic/IoTDBPipeAutoSplitIT.java
index 2ebad93348c..5be609aba2f 100644
---
a/integration-test/src/test/java/org/apache/iotdb/pipe/it/dual/treemodel/auto/basic/IoTDBPipeAutoSplitIT.java
+++
b/integration-test/src/test/java/org/apache/iotdb/pipe/it/dual/treemodel/auto/basic/IoTDBPipeAutoSplitIT.java
@@ -111,8 +111,8 @@ public class IoTDBPipeAutoSplitIT extends
AbstractPipeDualTreeModelAutoIT {
TestUtils.executeNonQueries(
senderEnv,
Arrays.asList(
- "drop pipe a2b_history",
- "drop pipe a2b_realtime",
+ "drop pipe if exists a2b_history",
+ "drop pipe if exists a2b_realtime",
String.format(
"create pipe a2b1 with source ('inclusion'='schema') with sink
('node-urls'='%s')",
receiverDataNode.getIpAndPortString()),
