This is an automated email from the ASF dual-hosted git repository. justinchen pushed a commit to branch run-ci-mod in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit 40357cd805bfbb7e69a5748a6af88f81260b37ab Author: Caideyipi <[email protected]> AuthorDate: Thu Mar 26 11:30:09 2026 +0800 sz --- .../auto/AbstractPipeDualTreeModelAutoIT.java | 1 - .../treemodel/auto/basic/IoTDBPipeDataSinkIT.java | 19 +++++++++++++------ 2 files changed, 13 insertions(+), 7 deletions(-) diff --git a/integration-test/src/test/java/org/apache/iotdb/pipe/it/dual/treemodel/auto/AbstractPipeDualTreeModelAutoIT.java b/integration-test/src/test/java/org/apache/iotdb/pipe/it/dual/treemodel/auto/AbstractPipeDualTreeModelAutoIT.java index 0169c9fb438..ed007a582a7 100644 --- a/integration-test/src/test/java/org/apache/iotdb/pipe/it/dual/treemodel/auto/AbstractPipeDualTreeModelAutoIT.java +++ b/integration-test/src/test/java/org/apache/iotdb/pipe/it/dual/treemodel/auto/AbstractPipeDualTreeModelAutoIT.java @@ -25,7 +25,6 @@ import org.apache.iotdb.db.it.utils.TestUtils; import org.apache.iotdb.it.env.EnvFactory; import org.apache.iotdb.it.env.MultiEnvFactory; import org.apache.iotdb.it.env.cluster.node.DataNodeWrapper; -import org.apache.iotdb.it.env.remote.env.RemoteServerEnv; import org.apache.iotdb.itbase.env.BaseEnv; import org.awaitility.Awaitility; diff --git a/integration-test/src/test/java/org/apache/iotdb/pipe/it/dual/treemodel/auto/basic/IoTDBPipeDataSinkIT.java b/integration-test/src/test/java/org/apache/iotdb/pipe/it/dual/treemodel/auto/basic/IoTDBPipeDataSinkIT.java index a854f80591f..07d31df2050 100644 --- a/integration-test/src/test/java/org/apache/iotdb/pipe/it/dual/treemodel/auto/basic/IoTDBPipeDataSinkIT.java +++ b/integration-test/src/test/java/org/apache/iotdb/pipe/it/dual/treemodel/auto/basic/IoTDBPipeDataSinkIT.java @@ -615,11 +615,18 @@ public class IoTDBPipeDataSinkIT extends AbstractPipeDualTreeModelAutoIT { "create pipe test with source ('source.realtime.mode'='stream','inclusion'='data','path'='root.sg_nonAligned.非对齐序列带有encoding和压缩方式.**','source.realtime.enable'='true','mods.enable'='true') with sink ('sink'='iotdb-thrift-sink', 'sink.node-urls'='%s')", receiverEnv.getDataNodeWrapperList().get(0).getIpAndPortString()))); - TestUtils.assertDataEventuallyOnEnv( - receiverEnv, - "count timeseries root.sg_nonAligned.非对齐序列带有encoding和压缩方式.*", - "count(timeseries),", - Collections.singleton("4,"), - 30); + try { + TestUtils.assertDataEventuallyOnEnv( + receiverEnv, + "count timeseries root.sg_nonAligned.非对齐序列带有encoding和压缩方式.*", + "count(timeseries),", + Collections.singleton("4,"), + 30); + } finally { + TestUtils.executeNonQueries( + senderEnv, + Arrays.asList( + "drop pipe test_history", "drop pipe test_realtime", "drop database root.**")); + } } }
