You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by ma...@apache.org on 2023/05/25 10:18:51 UTC
[iotdb] branch add-level-file-metric created (now 4dda6c58d17)
This is an automated email from the ASF dual-hosted git repository.
marklau99 pushed a change to branch add-level-file-metric
in repository https://gitbox.apache.org/repos/asf/iotdb.git
at 4dda6c58d17 fix file metrics not correct
This branch includes the following new commits:
new 4dda6c58d17 fix file metrics not correct
The 1 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
[iotdb] 01/01: fix file metrics not correct
Posted by ma...@apache.org.
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 <li...@outlook.com>
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;
}
}