Trigger leader balance on long-term WAL write blocking

integration-test/src/main/java/org/apache/iotdb/it/env/cluster/config/MppCommonConfig.java

@@ -375,6 +375,19 @@ public CommonConfig setWalBufferSize(int walBufferSize) {
     return this;
   }
 
+  @Override
+  public CommonConfig setCheckPeriodWhenInsertBlocked(int checkPeriodWhenInsertBlocked) {
+    setProperty("check_period_when_insert_blocked", String.valueOf(checkPeriodWhenInsertBlocked));
+    return this;
+  }
+
+  @Override
+  public CommonConfig setMaxWaitingTimeWhenInsertBlocked(int maxWaitingTimeWhenInsertBlocked) {
+    setProperty(
+        "max_waiting_time_when_insert_blocked", String.valueOf(maxWaitingTimeWhenInsertBlocked));
+    return this;
+  }
+
   @Override
   public CommonConfig setDegreeOfParallelism(int degreeOfParallelism) {
     setProperty("degree_of_query_parallelism", String.valueOf(degreeOfParallelism));

integration-test/src/main/java/org/apache/iotdb/it/env/cluster/config/MppSharedCommonConfig.java

@@ -375,6 +375,20 @@ public CommonConfig setWalBufferSize(int walBufferSize) {
     return this;
   }
 
+  @Override
+  public CommonConfig setCheckPeriodWhenInsertBlocked(int checkPeriodWhenInsertBlocked) {
+    cnConfig.setCheckPeriodWhenInsertBlocked(checkPeriodWhenInsertBlocked);
+    dnConfig.setCheckPeriodWhenInsertBlocked(checkPeriodWhenInsertBlocked);
+    return this;
+  }
+
+  @Override
+  public CommonConfig setMaxWaitingTimeWhenInsertBlocked(int maxWaitingTimeWhenInsertBlocked) {
+    cnConfig.setMaxWaitingTimeWhenInsertBlocked(maxWaitingTimeWhenInsertBlocked);
+    dnConfig.setMaxWaitingTimeWhenInsertBlocked(maxWaitingTimeWhenInsertBlocked);
+    return this;
+  }
+
   @Override
   public CommonConfig setDegreeOfParallelism(int degreeOfParallelism) {
     cnConfig.setDegreeOfParallelism(degreeOfParallelism);

integration-test/src/main/java/org/apache/iotdb/it/env/remote/config/RemoteCommonConfig.java

@@ -264,6 +264,16 @@ public CommonConfig setWalBufferSize(int walBufferSize) {
     return this;
   }
 
+  @Override
+  public CommonConfig setCheckPeriodWhenInsertBlocked(int checkPeriodWhenInsertBlocked) {
+    return this;
+  }
+
+  @Override
+  public CommonConfig setMaxWaitingTimeWhenInsertBlocked(int maxWaitingTimeWhenInsertBlocked) {
+    return this;
+  }
+
   @Override
   public CommonConfig setDegreeOfParallelism(int degreeOfParallelism) {
     return this;

integration-test/src/main/java/org/apache/iotdb/itbase/env/CommonConfig.java

@@ -120,6 +120,10 @@ CommonConfig setEnableAutoLeaderBalanceForIoTConsensus(
 
   CommonConfig setWalBufferSize(int walBufferSize);
 
+  CommonConfig setCheckPeriodWhenInsertBlocked(int checkPeriodWhenInsertBlocked);
+
+  CommonConfig setMaxWaitingTimeWhenInsertBlocked(int maxWaitingTimeWhenInsertBlocked);
+
   CommonConfig setDegreeOfParallelism(int degreeOfParallelism);
 
   CommonConfig setDataRatisTriggerSnapshotThreshold(long threshold);