(iotdb) branch dev/1.3 updated: Fix bug that the partition table auto cleaner cannot be activated (#15158) (#15162)

[tanxinyu]

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

tanxinyu pushed a commit to branch dev/1.3
in repository https://gitbox.apache.org/repos/asf/iotdb.git


The following commit(s) were added to refs/heads/dev/1.3 by this push:
     new af472c0c993 Fix bug that the partition table auto cleaner cannot be 
activated (#15158) (#15162)
af472c0c993 is described below

commit af472c0c9932707851a823491e077ca7e87079a3
Author: Yongzao <yong...@apache.org>
AuthorDate: Sat Mar 22 09:19:26 2025 +0800

    Fix bug that the partition table auto cleaner cannot be activated (#15158) 
(#15162)
    
    * 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));
     }
   }