This is an automated email from the ASF dual-hosted git repository. Caideyipi pushed a commit to branch it-fix-13 in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit 7301ca263e5d6c5736cd3070447e18448f3cc3be Author: Caideyipi <[email protected]> AuthorDate: Tue Jul 14 12:21:36 2026 +0800 Pipe IT: disable pipe memory control in overridden setups (#18198) --- .../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
