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 11a2b04a2c7a08226c9ab1d843d8c215c4335185..a24a6cdceec0cfab5a87f7da80c530a3f0724ea0 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 recoverListeners = new ArrayList<>(); for (List 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 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);