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/01/03 03:00:23 UTC
[iotdb] branch master updated: [IOTDB-5160] [Metric] Fix the file count of datanode become negative number
This is an automated email from the ASF dual-hosted git repository.
marklau99 pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/iotdb.git
The following commit(s) were added to refs/heads/master by this push:
new 8d180e45d1 [IOTDB-5160] [Metric] Fix the file count of datanode become negative number
8d180e45d1 is described below
commit 8d180e45d1910899cd34f80cb70e34a3ac06e239
Author: Liu Xuxin <37...@users.noreply.github.com>
AuthorDate: Tue Jan 3 11:00:17 2023 +0800
[IOTDB-5160] [Metric] Fix the file count of datanode become negative number
---
.../org/apache/iotdb/db/engine/storagegroup/DataRegion.java | 12 ++++++++++--
1 file changed, 10 insertions(+), 2 deletions(-)
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 11a2b04a2c..a24a6cdcee 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
@@ -457,10 +457,14 @@ public class DataRegion implements IDataRegionForQuery {
List<WALRecoverListener> recoverListeners = new ArrayList<>();
for (List<TsFileResource> value : partitionTmpSeqTsFiles.values()) {
// tsFiles without resource file are unsealed
+ for (TsFileResource resource : value) {
+ if (resource.resourceFileExists()) {
+ TsFileMetricManager.getInstance().addFile(resource.getTsFile().length(), true);
+ }
+ }
while (!value.isEmpty()) {
TsFileResource tsFileResource = value.get(value.size() - 1);
if (tsFileResource.resourceFileExists()) {
- TsFileMetricManager.getInstance().addFile(tsFileResource.getTsFile().length(), true);
break;
} else {
value.remove(value.size() - 1);
@@ -474,10 +478,14 @@ public class DataRegion implements IDataRegionForQuery {
}
for (List<TsFileResource> value : partitionTmpUnseqTsFiles.values()) {
// tsFiles without resource file are unsealed
+ for (TsFileResource resource : value) {
+ if (resource.resourceFileExists()) {
+ TsFileMetricManager.getInstance().addFile(resource.getTsFile().length(), false);
+ }
+ }
while (!value.isEmpty()) {
TsFileResource tsFileResource = value.get(value.size() - 1);
if (tsFileResource.resourceFileExists()) {
- TsFileMetricManager.getInstance().addFile(tsFileResource.getTsFile().length(), false);
break;
} else {
value.remove(value.size() - 1);