(iotdb) branch debug_partition_table_cleaner updated: stash for debug

[yongzao]

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

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


The following commit(s) were added to refs/heads/debug_partition_table_cleaner 
by this push:
     new f81ce8416b6 stash for debug
f81ce8416b6 is described below

commit f81ce8416b662e66eb04318ce912615d8e969384
Author: YongzaoDan <532741...@qq.com>
AuthorDate: Fri Mar 21 13:00:26 2025 +0800

    stash for debug
---
 .../apache/iotdb/confignode/procedure/PartitionTableAutoCleaner.java  | 4 ++++
 .../src/main/java/org/apache/iotdb/commons/conf/CommonConfig.java     | 2 +-
 2 files changed, 5 insertions(+), 1 deletion(-)

diff --git 
a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/PartitionTableAutoCleaner.java
 
b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/PartitionTableAutoCleaner.java
index 5daa95a34c8..51247848aea 100644
--- 
a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/PartitionTableAutoCleaner.java
+++ 
b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/PartitionTableAutoCleaner.java
@@ -55,6 +55,7 @@ public class PartitionTableAutoCleaner<Env> extends 
InternalProcedure<Env> {
 
   @Override
   protected void periodicExecute(Env env) {
+    LOGGER.info("[PartitionTableCleaner] Start periodic check");
     List<String> databases = 
configManager.getClusterSchemaManager().getDatabaseNames(null);
     Map<String, Long> databaseTTLMap = new TreeMap<>();
     for (String database : databases) {
@@ -71,6 +72,9 @@ public class PartitionTableAutoCleaner<Env> extends 
InternalProcedure<Env> {
       }
     }
     if (!databaseTTLMap.isEmpty()) {
+      LOGGER.info(
+          "[PartitionTableCleaner] Periodically activate 
PartitionTableAutoCleaner for: {}",
+          databaseTTLMap);
       // Only clean the partition table when necessary
       TTimePartitionSlot currentTimePartitionSlot =
           TimePartitionUtils.getCurrentTimePartitionSlot();
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 a06b6218831..9bd04b5da00 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
@@ -135,7 +135,7 @@ public class CommonConfig {
   private int ttlRuleCapacity = 1000;
 
   /** The interval of ttl check task in each database. The unit is ms. Default 
is 2 hours. */
-  private long ttlCheckInterval = 7_200_000L;
+  private long ttlCheckInterval = 30_000L;
 
   /** Thrift socket and connection timeout between data node and config node. 
*/
   private int cnConnectionTimeoutInMS = (int) TimeUnit.SECONDS.toMillis(60);