(iotdb) branch table_disk_usage_statistics_with_cache updated: fix bug

[shuwenwei]

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

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


The following commit(s) were added to 
refs/heads/table_disk_usage_statistics_with_cache by this push:
     new 271bd12f8aa fix bug
271bd12f8aa is described below

commit 271bd12f8aaf67c741db1d7ebba701f1e11a8cf9
Author: shuwenwei <s13979062...@gmail.com>
AuthorDate: Thu Feb 5 09:50:31 2026 +0800

    fix bug
---
 .../utils/tableDiskUsageCache/TableDiskUsageCache.java         | 10 +++++++---
 1 file changed, 7 insertions(+), 3 deletions(-)

diff --git 
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/utils/tableDiskUsageCache/TableDiskUsageCache.java
 
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/utils/tableDiskUsageCache/TableDiskUsageCache.java
index ee2eeff544d..e1dc29f9958 100644
--- 
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/utils/tableDiskUsageCache/TableDiskUsageCache.java
+++ 
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/utils/tableDiskUsageCache/TableDiskUsageCache.java
@@ -127,9 +127,7 @@ public class TableDiskUsageCache {
       if (writer.getActiveReaderNum() > 0) {
         continue;
       }
-      if (writer.tsFileCacheWriter.needCompact()) {
-        writer.tsFileCacheWriter.compact();
-      }
+      writer.compactIfNecessary();
     }
   }
 
@@ -485,6 +483,12 @@ public class TableDiskUsageCache {
       return activeReaderNum;
     }
 
+    public void compactIfNecessary() {
+      if (tsFileCacheWriter.needCompact()) {
+        tsFileCacheWriter.compact();
+      }
+    }
+
     public void closeIfIdle() {
       tsFileCacheWriter.closeIfIdle();
     }