Pipe/Subscription: Continue CI Fixing (#16084)

* may-final

* revert

Author: Caideyipi

integration-test/src/test/java/org/apache/iotdb/pipe/it/single/AbstractPipeSingleIT.java

@@ -33,10 +33,11 @@ abstract class AbstractPipeSingleIT {
   public void setUp() {
     MultiEnvFactory.createEnv(2);
     env = MultiEnvFactory.getEnv(0);
-    env.getConfig().getCommonConfig().setAutoCreateSchemaEnabled(true);
-    // 10 min, assert that the operations will not time out
-    env.getConfig().getCommonConfig().setDnConnectionTimeoutMs(600000);
-    env.getConfig().getCommonConfig().setIsPipeEnableMemoryCheck(false);
+    env.getConfig()
+        .getCommonConfig()
+        .setAutoCreateSchemaEnabled(true)
+        .setPipeMemoryManagementEnabled(false)
+        .setIsPipeEnableMemoryCheck(false);
     env.initClusterEnvironment();
   }
 

integration-test/src/test/java/org/apache/iotdb/subscription/it/dual/AbstractSubscriptionDualIT.java

@@ -60,8 +60,16 @@ protected void setUpConfig() {
     senderEnv.getConfig().getCommonConfig().setDnConnectionTimeoutMs(600000);
     receiverEnv.getConfig().getCommonConfig().setDnConnectionTimeoutMs(600000);
 
-    senderEnv.getConfig().getCommonConfig().setIsPipeEnableMemoryCheck(false);
-    receiverEnv.getConfig().getCommonConfig().setIsPipeEnableMemoryCheck(false);
+    senderEnv
+        .getConfig()
+        .getCommonConfig()
+        .setPipeMemoryManagementEnabled(false)
+        .setIsPipeEnableMemoryCheck(false);
+    receiverEnv
+        .getConfig()
+        .getCommonConfig()
+        .setPipeMemoryManagementEnabled(false)
+        .setIsPipeEnableMemoryCheck(false);
   }
 
   @Override

integration-test/src/test/java/org/apache/iotdb/subscription/it/dual/tablemodel/IoTDBSubscriptionTopicIT.java

@@ -81,8 +81,18 @@ protected void setUpConfig() {
         .getConfig()
         .getCommonConfig()
         .setPipeHeartbeatIntervalSecondsForCollectingPipeMeta(30);
-    senderEnv.getConfig().getCommonConfig().setPipeMetaSyncerInitialSyncDelayMinutes(1);
-    senderEnv.getConfig().getCommonConfig().setPipeMetaSyncerSyncIntervalMinutes(1);
+    senderEnv
+        .getConfig()
+        .getCommonConfig()
+        .setPipeMetaSyncerInitialSyncDelayMinutes(1)
+        .setPipeMemoryManagementEnabled(false)
+        .setIsPipeEnableMemoryCheck(false);
+    senderEnv
+        .getConfig()
+        .getCommonConfig()
+        .setPipeMetaSyncerSyncIntervalMinutes(1)
+        .setPipeMemoryManagementEnabled(false)
+        .setIsPipeEnableMemoryCheck(false);
   }
 
   @Test

integration-test/src/test/java/org/apache/iotdb/subscription/it/dual/treemodel/IoTDBSubscriptionConsumerGroupIT.java

@@ -118,11 +118,19 @@ static final class SubscriptionInfo {
   protected void setUpConfig() {
     super.setUpConfig();
 
-    senderEnv.getConfig().getCommonConfig().setIsPipeEnableMemoryCheck(false);
+    senderEnv
+        .getConfig()
+        .getCommonConfig()
+        .setPipeMemoryManagementEnabled(false)
+        .setIsPipeEnableMemoryCheck(false);
 
     // Enable air gap receiver
     receiverEnv.getConfig().getCommonConfig().setPipeAirGapReceiverEnabled(true);
-    receiverEnv.getConfig().getCommonConfig().setIsPipeEnableMemoryCheck(false);
+    receiverEnv
+        .getConfig()
+        .getCommonConfig()
+        .setPipeMemoryManagementEnabled(false)
+        .setIsPipeEnableMemoryCheck(false);
   }
 
   @Override

integration-test/src/test/java/org/apache/iotdb/subscription/it/dual/treemodel/IoTDBSubscriptionTimePrecisionIT.java

@@ -69,9 +69,17 @@ protected void setUpConfig() {
 
     // Set timestamp precision to nanosecond
     senderEnv.getConfig().getCommonConfig().setTimestampPrecision("ns");
-    senderEnv.getConfig().getCommonConfig().setIsPipeEnableMemoryCheck(false);
+    senderEnv
+        .getConfig()
+        .getCommonConfig()
+        .setPipeMemoryManagementEnabled(false)
+        .setIsPipeEnableMemoryCheck(false);
     receiverEnv.getConfig().getCommonConfig().setTimestampPrecision("ns");
-    receiverEnv.getConfig().getCommonConfig().setIsPipeEnableMemoryCheck(false);
+    receiverEnv
+        .getConfig()
+        .getCommonConfig()
+        .setPipeMemoryManagementEnabled(false)
+        .setIsPipeEnableMemoryCheck(false);
   }
 
   @Test

integration-test/src/test/java/org/apache/iotdb/subscription/it/dual/treemodel/IoTDBSubscriptionTopicIT.java

@@ -92,9 +92,17 @@ protected void setUpConfig() {
         .setPipeHeartbeatIntervalSecondsForCollectingPipeMeta(30);
     senderEnv.getConfig().getCommonConfig().setPipeMetaSyncerInitialSyncDelayMinutes(1);
     senderEnv.getConfig().getCommonConfig().setPipeMetaSyncerSyncIntervalMinutes(1);
-    senderEnv.getConfig().getCommonConfig().setIsPipeEnableMemoryCheck(false);
+    senderEnv
+        .getConfig()
+        .getCommonConfig()
+        .setPipeMemoryManagementEnabled(false)
+        .setIsPipeEnableMemoryCheck(false);
 
-    receiverEnv.getConfig().getCommonConfig().setIsPipeEnableMemoryCheck(false);
+    receiverEnv
+        .getConfig()
+        .getCommonConfig()
+        .setPipeMemoryManagementEnabled(false)
+        .setIsPipeEnableMemoryCheck(false);
   }
 
   @Test

integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/AbstractSubscriptionTripleIT.java

@@ -83,8 +83,16 @@ protected void setUpConfig() {
     receiver1.getConfig().getConfigNodeConfig().setLeaderDistributionPolicy("HASH");
     receiver2.getConfig().getConfigNodeConfig().setLeaderDistributionPolicy("HASH");
 
-    receiver1.getConfig().getCommonConfig().setIsPipeEnableMemoryCheck(false);
-    receiver2.getConfig().getCommonConfig().setIsPipeEnableMemoryCheck(false);
+    receiver1
+        .getConfig()
+        .getCommonConfig()
+        .setPipeMemoryManagementEnabled(false)
+        .setIsPipeEnableMemoryCheck(false);
+    receiver2
+        .getConfig()
+        .getCommonConfig()
+        .setPipeMemoryManagementEnabled(false)
+        .setIsPipeEnableMemoryCheck(false);
   }
 
   @Override