(iotdb) branch run-ci-mod updated: 5

[justinchen]

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


The following commit(s) were added to refs/heads/run-ci-mod by this push:
     new 8e9b3fa4934 5
8e9b3fa4934 is described below

commit 8e9b3fa4934d1e9102ddb6f7b381c8a8ee3714a0
Author: Caideyipi <87789683+caidey...@users.noreply.github.com>
AuthorDate: Thu Mar 26 11:08:07 2026 +0800

    5
---
 .../pipe/it/dual/treemodel/auto/basic/IoTDBPipeDataSinkIT.java      | 6 ++++--
 1 file changed, 4 insertions(+), 2 deletions(-)

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 29655ceb24c..a854f80591f 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
@@ -611,13 +611,15 @@ public class IoTDBPipeDataSinkIT extends 
AbstractPipeDualTreeModelAutoIT {
         senderEnv,
         Arrays.asList(
             "delete timeseries root.sg_nonAligned.非对齐序列带有encoding和压缩方式.s1",
-            "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'='192.168.130.19:6667')"));
+            String.format(
+                "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,"),
-        20);
+        30);
   }
 }