This is an automated email from the ASF dual-hosted git repository. neuyilan pushed a commit to branch bugfix/apache_rel_1.0_file_size in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit ee8bcf14206ce1cb14d7e6f522b87ee20b12c345 Author: HouliangQi <[email protected]> AuthorDate: Wed Dec 28 10:14:26 2022 +0800 fix the file size is incorrect when datanode restart --- .../main/java/org/apache/iotdb/db/engine/storagegroup/DataRegion.java | 2 -- 1 file changed, 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 0be9f26df5..ee7868cd0b 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 @@ -455,7 +455,6 @@ public class DataRegion implements IDataRegionForQuery { TsFileResource tsFileResource = value.get(value.size() - 1); if (tsFileResource.resourceFileExists()) { TsFileMetricManager.getInstance().addFile(tsFileResource.getTsFile().length(), true); - break; } else { value.remove(value.size() - 1); WALRecoverListener recoverListener = @@ -472,7 +471,6 @@ public class DataRegion implements IDataRegionForQuery { TsFileResource tsFileResource = value.get(value.size() - 1); if (tsFileResource.resourceFileExists()) { TsFileMetricManager.getInstance().addFile(tsFileResource.getTsFile().length(), false); - break; } else { value.remove(value.size() - 1); WALRecoverListener recoverListener =
