(iotdb) branch master updated: Pipe IT: Moved rate-limiter in zstd-test to non-tested pipe to avoid blocking potential failure (#16347)

[justinchen]

This is an automated email from the ASF dual-hosted git repository.

justinchen 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 164b58140a2 Pipe IT: Moved rate-limiter in zstd-test to non-tested 
pipe to avoid blocking potential failure (#16347)
164b58140a2 is described below

commit 164b58140a25ed7186a549b3b92c65b3f702e4b0
Author: Caideyipi <87789683+caidey...@users.noreply.github.com>
AuthorDate: Thu Sep 4 20:31:37 2025 +0800

    Pipe IT: Moved rate-limiter in zstd-test to non-tested pipe to avoid 
blocking potential failure (#16347)
---
 .../dual/tablemodel/manual/enhanced/IoTDBPipeSinkCompressionIT.java | 6 +++---
 1 file changed, 3 insertions(+), 3 deletions(-)

diff --git 
a/integration-test/src/test/java/org/apache/iotdb/pipe/it/dual/tablemodel/manual/enhanced/IoTDBPipeSinkCompressionIT.java
 
b/integration-test/src/test/java/org/apache/iotdb/pipe/it/dual/tablemodel/manual/enhanced/IoTDBPipeSinkCompressionIT.java
index 74c43b8df34..e91b156e09c 100644
--- 
a/integration-test/src/test/java/org/apache/iotdb/pipe/it/dual/tablemodel/manual/enhanced/IoTDBPipeSinkCompressionIT.java
+++ 
b/integration-test/src/test/java/org/apache/iotdb/pipe/it/dual/tablemodel/manual/enhanced/IoTDBPipeSinkCompressionIT.java
@@ -258,8 +258,7 @@ public class IoTDBPipeSinkCompressionIT extends 
AbstractPipeTableModelDualManual
                     + "'connector.ip'='%s',"
                     + "'connector.port'='%s',"
                     + "'connector.compressor'='zstd, zstd',"
-                    + "'connector.compressor.zstd.level'='3',"
-                    + "'connector.rate-limit-bytes-per-second'='2048.0')",
+                    + "'connector.compressor.zstd.level'='3')",
                 receiverIp, receiverPort));
       } catch (SQLException e) {
         e.printStackTrace();
@@ -276,7 +275,8 @@ public class IoTDBPipeSinkCompressionIT extends 
AbstractPipeTableModelDualManual
                     + "'connector.ip'='%s',"
                     + "'connector.port'='%s',"
                     + "'connector.compressor'='zstd, zstd',"
-                    + "'connector.compressor.zstd.level'='22')",
+                    + "'connector.compressor.zstd.level'='22',"
+                    + "'connector.rate-limit-bytes-per-second'='2048.0')",
                 receiverIp, receiverPort));
       } catch (SQLException e) {
         e.printStackTrace();