(iotdb) branch cp-52d1df65 updated: Fix bug that the partition table auto cleaner cannot be activated (#15158)

[yongzao]

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

yongzao pushed a commit to branch cp-52d1df65
in repository https://gitbox.apache.org/repos/asf/iotdb.git


The following commit(s) were added to refs/heads/cp-52d1df65 by this push:
     new 1d26a09bc5b Fix bug that the partition table auto cleaner cannot be 
activated (#15158)
1d26a09bc5b is described below

commit 1d26a09bc5b56d51eaf0a41bb3b9de68590121d8
Author: Yongzao <yong...@apache.org>
AuthorDate: Fri Mar 21 17:16:36 2025 +0800

    Fix bug that the partition table auto cleaner cannot be activated (#15158)
    
    * stash for debug
    
    * fix comparator (#15157)
    
    LGTM!!!
    
    * adjust logs
    
    ---------
    
    Co-authored-by: Li Yu Heng <liyuheng55...@126.com>
---
 .../apache/iotdb/confignode/procedure/PartitionTableAutoCleaner.java   | 3 +++
 .../org/apache/iotdb/confignode/procedure/TimeoutExecutorThread.java   | 2 +-
 2 files changed, 4 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 a4918e6bfb6..ce5d07276db 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
@@ -67,6 +67,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/confignode/src/main/java/org/apache/iotdb/confignode/procedure/TimeoutExecutorThread.java
 
b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/TimeoutExecutorThread.java
index d4f919c01be..5aaf9a623f5 100644
--- 
a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/TimeoutExecutorThread.java
+++ 
b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/TimeoutExecutorThread.java
@@ -100,7 +100,7 @@ public class TimeoutExecutorThread<Env> extends 
StoppableThread {
 
     @Override
     public int compareTo(Delayed other) {
-      return Long.compareUnsigned(
+      return Long.compare(
           this.getDelay(TimeUnit.MILLISECONDS), 
other.getDelay(TimeUnit.MILLISECONDS));
     }
   }