未验证 提交 8d180e45 编写于 作者: L Liu Xuxin 提交者: GitHub

[IOTDB-5160] [Metric] Fix the file count of datanode become negative number

上级 78e67aaa
......@@ -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);
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册