Skip to content

Commit 170cd74

Browse files
authored
Pipe: fix manual IT pipe memory config (#18109)
1 parent b7285af commit 170cd74

3 files changed

Lines changed: 23 additions & 4 deletions

File tree

integration-test/src/test/java/org/apache/iotdb/pipe/it/manual/IoTDBPipeMetaHistoricalIT.java

Lines changed: 8 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -60,7 +60,10 @@ public void setUp() {
6060
.setDefaultSchemaRegionGroupNumPerDatabase(1)
6161
.setTimestampPrecision("ms")
6262
.setConfigNodeConsensusProtocolClass(ConsensusFactory.RATIS_CONSENSUS)
63-
.setSchemaRegionConsensusProtocolClass(ConsensusFactory.RATIS_CONSENSUS);
63+
.setSchemaRegionConsensusProtocolClass(ConsensusFactory.RATIS_CONSENSUS)
64+
.setPipeMemoryManagementEnabled(false)
65+
.setIsPipeEnableMemoryCheck(false)
66+
.setPipeAutoSplitFullEnabled(false);
6467
receiverEnv
6568
.getConfig()
6669
.getCommonConfig()
@@ -70,7 +73,10 @@ public void setUp() {
7073
.setSchemaRegionConsensusProtocolClass(ConsensusFactory.RATIS_CONSENSUS)
7174
.setDataRegionConsensusProtocolClass(ConsensusFactory.IOT_CONSENSUS)
7275
.setSchemaReplicationFactor(3)
73-
.setDataReplicationFactor(2);
76+
.setDataReplicationFactor(2)
77+
.setPipeMemoryManagementEnabled(false)
78+
.setIsPipeEnableMemoryCheck(false)
79+
.setPipeAutoSplitFullEnabled(false);
7480

7581
// 10 min, assert that the operations will not time out
7682
senderEnv.getConfig().getCommonConfig().setDnConnectionTimeoutMs(600000);

integration-test/src/test/java/org/apache/iotdb/pipe/it/manual/IoTDBPipeMetaLeaderChangeIT.java

Lines changed: 11 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -56,11 +56,20 @@ public void setUp() {
5656
.setConfigNodeConsensusProtocolClass(ConsensusFactory.RATIS_CONSENSUS)
5757
.setSchemaRegionConsensusProtocolClass(ConsensusFactory.RATIS_CONSENSUS)
5858
.setDataRegionConsensusProtocolClass(ConsensusFactory.IOT_CONSENSUS)
59-
.setSchemaReplicationFactor(3);
59+
.setSchemaReplicationFactor(3)
60+
.setPipeMemoryManagementEnabled(false)
61+
.setIsPipeEnableMemoryCheck(false)
62+
.setPipeAutoSplitFullEnabled(false);
6063

6164
// 10 min, assert that the operations will not time out
6265
senderEnv.getConfig().getCommonConfig().setDnConnectionTimeoutMs(600000);
63-
receiverEnv.getConfig().getCommonConfig().setDnConnectionTimeoutMs(600000);
66+
receiverEnv
67+
.getConfig()
68+
.getCommonConfig()
69+
.setPipeMemoryManagementEnabled(false)
70+
.setIsPipeEnableMemoryCheck(false)
71+
.setPipeAutoSplitFullEnabled(false)
72+
.setDnConnectionTimeoutMs(600000);
6473

6574
senderEnv.initClusterEnvironment(3, 3, 180);
6675
receiverEnv.initClusterEnvironment();

integration-test/src/test/java/org/apache/iotdb/pipe/it/manual/IoTDBPipePermissionIT.java

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -63,6 +63,8 @@ public void setUp() {
6363
.setTimestampPrecision("ms")
6464
.setConfigNodeConsensusProtocolClass(ConsensusFactory.RATIS_CONSENSUS)
6565
.setSchemaRegionConsensusProtocolClass(ConsensusFactory.RATIS_CONSENSUS)
66+
.setPipeMemoryManagementEnabled(false)
67+
.setIsPipeEnableMemoryCheck(false)
6668
.setPipeAutoSplitFullEnabled(false);
6769
receiverEnv
6870
.getConfig()
@@ -74,6 +76,8 @@ public void setUp() {
7476
.setDataRegionConsensusProtocolClass(ConsensusFactory.IOT_CONSENSUS)
7577
.setSchemaReplicationFactor(3)
7678
.setDataReplicationFactor(2)
79+
.setPipeMemoryManagementEnabled(false)
80+
.setIsPipeEnableMemoryCheck(false)
7781
.setPipeAutoSplitFullEnabled(false);
7882

7983
// 10 min, assert that the operations will not time out

0 commit comments

Comments
 (0)