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; } }
