This is an automated email from the ASF dual-hosted git repository. xingtanzjr pushed a commit to branch compaction_recover_logger_1017 in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit eecab62b3943211709ea97c951b06ae98e1f3a75 Author: Jinrui.Zhang <[email protected]> AuthorDate: Wed Oct 18 15:57:51 2023 +0800 fix the bug that source file may be inserted back to TsFileManager although it is not removed before --- .../dataregion/compaction/execute/task/AbstractCompactionTask.java | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/compaction/execute/task/AbstractCompactionTask.java b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/compaction/execute/task/AbstractCompactionTask.java index 3be3ee32fd7..d7d5c36687f 100644 --- a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/compaction/execute/task/AbstractCompactionTask.java +++ b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/compaction/execute/task/AbstractCompactionTask.java @@ -248,7 +248,9 @@ public abstract class AbstractCompactionTask { protected void insertFilesToTsFileManager(List<TsFileResource> tsFiles) throws IOException { for (TsFileResource tsFileResource : tsFiles) { - tsFileManager.keepOrderInsert(tsFileResource, tsFileResource.isSeq()); + if (!tsFileResource.isFileInList()) { + tsFileManager.keepOrderInsert(tsFileResource, tsFileResource.isSeq()); + } } }
