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

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


The following commit(s) were added to refs/heads/EnhancedDeviceCrossRegionIT by 
this push:
     new de411a6e9b5 Change back default config
de411a6e9b5 is described below

commit de411a6e9b583a19e1f8cefbba9f57b78ba5d94f
Author: JackieTien97 <[email protected]>
AuthorDate: Wed Sep 3 10:19:57 2025 +0800

    Change back default config
---
 .../iotdb/confignode/conf/ConfigNodeConfig.java    |  2 +-
 .../apache/iotdb/commons/conf/CommonConfig.java    | 25 +++++++++++++++++-----
 2 files changed, 21 insertions(+), 6 deletions(-)

diff --git 
a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/conf/ConfigNodeConfig.java
 
b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/conf/ConfigNodeConfig.java
index 12e1224d58d..57e619a9baa 100644
--- 
a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/conf/ConfigNodeConfig.java
+++ 
b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/conf/ConfigNodeConfig.java
@@ -82,7 +82,7 @@ public class ConfigNodeConfig {
   private String seriesPartitionExecutorClass =
       "org.apache.iotdb.commons.partition.executor.hash.BKDRHashExecutor";
 
-  private String dataPartitionAllocationStrategy = "SHUFFLE";
+  private String dataPartitionAllocationStrategy = "INHERIT";
 
   /** The policy of extension SchemaRegionGroup for each Database. */
   private RegionGroupExtensionPolicy schemaRegionGroupExtensionPolicy =
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 bb85c74940e..817bb3a494e 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
@@ -179,7 +179,7 @@ public class CommonConfig {
   private long timePartitionOrigin = 0;
 
   /** Time partition interval in milliseconds. */
-  private long timePartitionInterval = 60_000;
+  private long timePartitionInterval = 604_800_000;
 
   /** This variable set timestamp precision as millisecond, microsecond or 
nanosecond. */
   private String timestampPrecision = "ms";
@@ -329,6 +329,7 @@ public class CommonConfig {
   private volatile double 
pipeThresholdAllocationStrategyFixedMemoryHighUsageThreshold = 0.8d;
   private volatile boolean pipeTransferTsFileSync = false;
   private volatile long pipeCheckAllSyncClientLiveTimeIntervalMs = 5 * 60 * 
1000L; // 5 minutes
+  private int pipeTsFileResourceSegmentLockNum = -1;
 
   private long twoStageAggregateMaxCombinerLiveTimeInMs = 8 * 60 * 1000L; // 8 
minutes
   private long twoStageAggregateDataRegionInfoCacheTimeInMs = 3 * 60 * 1000L; 
// 3 minutes
@@ -1942,14 +1943,28 @@ public class CommonConfig {
   }
 
   public void setPipeCheckAllSyncClientLiveTimeIntervalMs(
-      long pipeCheckSyncAllClientLiveTimeIntervalMs) {
-    if (this.pipeCheckAllSyncClientLiveTimeIntervalMs == 
pipeCheckSyncAllClientLiveTimeIntervalMs) {
+      long pipeCheckAllSyncClientLiveTimeIntervalMs) {
+    if (this.pipeCheckAllSyncClientLiveTimeIntervalMs == 
pipeCheckAllSyncClientLiveTimeIntervalMs) {
       return;
     }
-    this.pipeCheckAllSyncClientLiveTimeIntervalMs = 
pipeCheckSyncAllClientLiveTimeIntervalMs;
+    this.pipeCheckAllSyncClientLiveTimeIntervalMs = 
pipeCheckAllSyncClientLiveTimeIntervalMs;
     logger.info(
         "pipeCheckSyncAllClientLiveTimeIntervalMs is set to {}",
-        pipeCheckSyncAllClientLiveTimeIntervalMs);
+        pipeCheckAllSyncClientLiveTimeIntervalMs);
+  }
+
+  public int getPipeTsFileResourceSegmentLockNum() {
+    return pipeTsFileResourceSegmentLockNum;
+  }
+
+  public void setPipeTsFileResourceSegmentLockNum(int 
pipeTsFileResourceSegmentLockNum) {
+    if (this.pipeTsFileResourceSegmentLockNum == 
pipeTsFileResourceSegmentLockNum) {
+      return;
+    }
+    this.pipeTsFileResourceSegmentLockNum = pipeTsFileResourceSegmentLockNum;
+    logger.info(
+        "pipeCheckSyncAllClientLiveTimeIntervalMs is set to {}",
+        pipeCheckAllSyncClientLiveTimeIntervalMs);
   }
 
   public double getPipeSendTsFileRateLimitBytesPerSecond() {

Reply via email to