This is an automated email from the ASF dual-hosted git repository.
jt2594838 pushed a commit to branch dev/1.3
in repository https://gitbox.apache.org/repos/asf/iotdb.git
The following commit(s) were added to refs/heads/dev/1.3 by this push:
new db2dfe965a9 Pipe IT: disable pipe memory control in overridden setups
(#18198) (#18205)
db2dfe965a9 is described below
commit db2dfe965a9fa65fd75319f032d3359740971695
Author: Caideyipi <[email protected]>
AuthorDate: Wed Jul 15 09:48:31 2026 +0800
Pipe IT: disable pipe memory control in overridden setups (#18198) (#18205)
---
.../iotdb/pipe/it/autocreate/IoTDBPipeProtocolIT.java | 16 ++++++++++++----
iotdb-client/client-go | 2 +-
2 files changed, 13 insertions(+), 5 deletions(-)
diff --git
a/integration-test/src/test/java/org/apache/iotdb/pipe/it/autocreate/IoTDBPipeProtocolIT.java
b/integration-test/src/test/java/org/apache/iotdb/pipe/it/autocreate/IoTDBPipeProtocolIT.java
index dfaa2b73b0e..c9ef7a9da95 100644
---
a/integration-test/src/test/java/org/apache/iotdb/pipe/it/autocreate/IoTDBPipeProtocolIT.java
+++
b/integration-test/src/test/java/org/apache/iotdb/pipe/it/autocreate/IoTDBPipeProtocolIT.java
@@ -171,7 +171,9 @@ public class IoTDBPipeProtocolIT extends
AbstractPipeDualAutoIT {
.setSchemaRegionConsensusProtocolClass(ConsensusFactory.RATIS_CONSENSUS)
.setDataRegionConsensusProtocolClass(ConsensusFactory.IOT_CONSENSUS)
.setSchemaReplicationFactor(3)
- .setDataReplicationFactor(2);
+ .setDataReplicationFactor(2)
+ .setPipeMemoryManagementEnabled(false)
+ .setIsPipeEnableMemoryCheck(false);
receiverEnv
.getConfig()
.getCommonConfig()
@@ -180,7 +182,9 @@ public class IoTDBPipeProtocolIT extends
AbstractPipeDualAutoIT {
.setSchemaRegionConsensusProtocolClass(ConsensusFactory.RATIS_CONSENSUS)
.setDataRegionConsensusProtocolClass(ConsensusFactory.IOT_CONSENSUS)
.setSchemaReplicationFactor(1)
- .setDataReplicationFactor(1);
+ .setDataReplicationFactor(1)
+ .setPipeMemoryManagementEnabled(false)
+ .setIsPipeEnableMemoryCheck(false);
// 10 min, assert that the operations will not time out
senderEnv.getConfig().getCommonConfig().setDnConnectionTimeoutMs(600000);
@@ -350,7 +354,9 @@ public class IoTDBPipeProtocolIT extends
AbstractPipeDualAutoIT {
.setDataReplicationFactor(1)
.setEnableSeqSpaceCompaction(false)
.setEnableUnseqSpaceCompaction(false)
- .setEnableCrossSpaceCompaction(false);
+ .setEnableCrossSpaceCompaction(false)
+ .setPipeMemoryManagementEnabled(false)
+ .setIsPipeEnableMemoryCheck(false);
receiverEnv
.getConfig()
.getCommonConfig()
@@ -360,7 +366,9 @@ public class IoTDBPipeProtocolIT extends
AbstractPipeDualAutoIT {
.setSchemaRegionConsensusProtocolClass(ConsensusFactory.RATIS_CONSENSUS)
.setDataRegionConsensusProtocolClass(ConsensusFactory.IOT_CONSENSUS)
.setSchemaReplicationFactor(3)
- .setDataReplicationFactor(2);
+ .setDataReplicationFactor(2)
+ .setPipeMemoryManagementEnabled(false)
+ .setIsPipeEnableMemoryCheck(false);
// 10 min, assert that the operations will not time out
senderEnv.getConfig().getCommonConfig().setDnConnectionTimeoutMs(600000);
diff --git a/iotdb-client/client-go b/iotdb-client/client-go
index dc64b1a7648..2ea2655e090 160000
--- a/iotdb-client/client-go
+++ b/iotdb-client/client-go
@@ -1 +1 @@
-Subproject commit dc64b1a7648d3c505c10eed5419f422bb49f1def
+Subproject commit 2ea2655e090dcefd12bf1a789a51c8df9a28fa24
