(iotdb) branch master updated: [Subscription] Increase consensus catch-up batch size (#18739)

[jiangtian]

This is an automated email from the ASF dual-hosted git repository.

jt2594838 pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/iotdb.git


The following commit(s) were added to refs/heads/master by this push:
     new 3227bc1a219 [Subscription] Increase consensus catch-up batch size 
(#18739)
3227bc1a219 is described below

commit 3227bc1a219f19404755a71549317f5f41d1a0ee
Author: Caideyipi <87789683+caidey...@users.noreply.github.com>
AuthorDate: Tue Sep 29 15:38:36 2026 +0800

    [Subscription] Increase consensus catch-up batch size (#18739)
---
 .../src/main/java/org/apache/iotdb/commons/conf/CommonConfig.java | 6 ++++--
 .../test/java/org/apache/iotdb/commons/conf/CommonConfigTest.java | 8 ++++++++
 2 files changed, 12 insertions(+), 2 deletions(-)

diff --git 
a/iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/conf/CommonConfig.java
 
b/iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/conf/CommonConfig.java
index 6b26b9d544d..8a5b7e088ce 100644
--- 
a/iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/conf/CommonConfig.java
+++ 
b/iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/conf/CommonConfig.java
@@ -426,8 +426,10 @@ public class CommonConfig {
 
   private int subscriptionConsensusBatchMaxDelayInMs = 50;
   private long subscriptionConsensusBatchMaxSizeInBytes = 8 * MB;
-  private int subscriptionConsensusBatchMaxTabletCount = 64;
-  private int subscriptionConsensusBatchMaxWalEntries = 128;
+  // Favor fewer poll/commit round trips during WAL catch-up. The byte limit 
remains the primary
+  // memory and RPC payload guard for large tablets.
+  private int subscriptionConsensusBatchMaxTabletCount = 512;
+  private int subscriptionConsensusBatchMaxWalEntries = 1024;
 
   private long subscriptionConsensusWalRetentionSizeInBytes = 512 * MB;
   private long subscriptionConsensusWalRetentionTimeMs = -1L;
diff --git 
a/iotdb-core/node-commons/src/test/java/org/apache/iotdb/commons/conf/CommonConfigTest.java
 
b/iotdb-core/node-commons/src/test/java/org/apache/iotdb/commons/conf/CommonConfigTest.java
index 2a38ad388d5..ac03de41317 100644
--- 
a/iotdb-core/node-commons/src/test/java/org/apache/iotdb/commons/conf/CommonConfigTest.java
+++ 
b/iotdb-core/node-commons/src/test/java/org/apache/iotdb/commons/conf/CommonConfigTest.java
@@ -42,6 +42,14 @@ public class CommonConfigTest {
     
assertNull(ConfigurationFileUtils.getConfigurationDefaultValue("subscription_enabled"));
   }
 
+  @Test
+  public void testConsensusSubscriptionCatchUpBatchDefaults() {
+    final CommonConfig config = new CommonConfig();
+
+    Assert.assertEquals(512, 
config.getSubscriptionConsensusBatchMaxTabletCount());
+    Assert.assertEquals(1024, 
config.getSubscriptionConsensusBatchMaxWalEntries());
+  }
+
   @Test
   public void testSameNodeStatusDoesNotClearStatusReason() {
     CommonConfig config = new CommonConfig();