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

marklau99 pushed a commit to branch add-level-file-metric
in repository https://gitbox.apache.org/repos/asf/iotdb.git

commit 4dda6c58d17b31af0dd9c827f24295d4b67b500a
Author: Liu Xuxin <[email protected]>
AuthorDate: Thu May 25 18:18:31 2023 +0800

    fix file metrics not correct
---
 .../java/org/apache/iotdb/db/engine/storagegroup/DataRegion.java     | 5 +++++
 1 file changed, 5 insertions(+)

diff --git 
a/server/src/main/java/org/apache/iotdb/db/engine/storagegroup/DataRegion.java 
b/server/src/main/java/org/apache/iotdb/db/engine/storagegroup/DataRegion.java
index ecf6ccc900f..dd90e5f2511 100644
--- 
a/server/src/main/java/org/apache/iotdb/db/engine/storagegroup/DataRegion.java
+++ 
b/server/src/main/java/org/apache/iotdb/db/engine/storagegroup/DataRegion.java
@@ -1609,6 +1609,7 @@ public class DataRegion implements IDataRegionForQuery {
     if (resource.tryWriteLock()) {
       try {
         // try to delete physical data file
+        TsFileMetricManager.getInstance().deleteFile(resource.getTsFileSize(), 
isSeq, 1);
         resource.remove();
         tsFileManager.remove(resource, isSeq);
         logger.info(
@@ -2722,6 +2723,8 @@ public class DataRegion implements IDataRegionForQuery {
         if 
(sequenceResource.getTsFile().getName().equals(fileToBeUnloaded.getName())) {
           tsFileResourceToBeMoved = sequenceResource;
           tsFileManager.remove(tsFileResourceToBeMoved, true);
+          TsFileMetricManager.getInstance()
+              .deleteFile(tsFileResourceToBeMoved.getTsFileSize(), true, 1);
           break;
         }
       }
@@ -2732,6 +2735,8 @@ public class DataRegion implements IDataRegionForQuery {
           if 
(unsequenceResource.getTsFile().getName().equals(fileToBeUnloaded.getName())) {
             tsFileResourceToBeMoved = unsequenceResource;
             tsFileManager.remove(tsFileResourceToBeMoved, false);
+            TsFileMetricManager.getInstance()
+                .deleteFile(tsFileResourceToBeMoved.getTsFileSize(), false, 1);
             break;
           }
         }

Reply via email to