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

rong 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 ff64e9e2c9b Load: Add mods file metrics count (#14930) (#14944)
ff64e9e2c9b is described below

commit ff64e9e2c9babf1f7ba73f7bc07cb0ce29470eed
Author: Zhenyu Luo <[email protected]>
AuthorDate: Tue Feb 25 18:44:26 2025 +0800

    Load: Add mods file metrics count (#14930) (#14944)
---
 .../java/org/apache/iotdb/db/storageengine/dataregion/DataRegion.java | 4 ++++
 1 file changed, 4 insertions(+)

diff --git 
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/DataRegion.java
 
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/DataRegion.java
index 07fc70b491f..42cf01d999f 100644
--- 
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/DataRegion.java
+++ 
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/DataRegion.java
@@ -3059,6 +3059,7 @@ public class DataRegion implements IDataRegionForQuery {
         logger.warn("Cannot delete localModFile {}", targetModFile, e);
       }
       try {
+        final long modFileSize = modFileToLoad.length();
         if (deleteOriginFile) {
           RetryUtils.retryOnException(
               () -> {
@@ -3072,6 +3073,9 @@ public class DataRegion implements IDataRegionForQuery {
                 return null;
               });
         }
+
+        FileMetrics.getInstance().increaseModFileNum(1);
+        FileMetrics.getInstance().increaseModFileSize(modFileSize);
       } catch (final IOException e) {
         logger.warn(
             "File renaming failed when loading .mod file. Origin: {}, Target: 
{}",

Reply via email to