You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by yo...@apache.org on 2025/04/29 07:38:25 UTC
(iotdb) branch partition-cleaner-log updated: Update PartitionTableAutoCleaner.java
This is an automated email from the ASF dual-hosted git repository.
yongzao pushed a commit to branch partition-cleaner-log
in repository https://gitbox.apache.org/repos/asf/iotdb.git
The following commit(s) were added to refs/heads/partition-cleaner-log by this push:
new 1394c1ae492 Update PartitionTableAutoCleaner.java
1394c1ae492 is described below
commit 1394c1ae49203b41d76ec0422ccbf9220d404be9
Author: Yongzao <53...@qq.com>
AuthorDate: Tue Apr 29 15:38:18 2025 +0800
Update PartitionTableAutoCleaner.java
---
.../iotdb/confignode/procedure/PartitionTableAutoCleaner.java | 6 ++++++
1 file changed, 6 insertions(+)
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 3c9690d3e29..a0baa3a77c7 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
@@ -63,6 +63,12 @@ public class PartitionTableAutoCleaner<Env> extends InternalProcedure<Env> {
? configManager.getClusterSchemaManager().getDatabaseMaxTTL(database)
: configManager.getTTLManager().getDatabaseMaxTTL(database);
databaseTTLMap.put(database, databaseTTL);
+ }
+ LOGGER.info(
+ "[PartitionTableCleaner] Periodically activate PartitionTableAutoCleaner, databaseTTL: {}",
+ databaseTTLMap);
+ for (String database : databases) {
+ long databaseTTL = databaseTTLMap.get(database);
if (!configManager.getPartitionManager().isDatabaseExist(database)
|| databaseTTL < 0
|| databaseTTL == Long.MAX_VALUE) {