This is an automated email from the ASF dual-hosted git repository.
jiangtian pushed a commit to branch rc/1.3.3
in repository https://gitbox.apache.org/repos/asf/iotdb.git
The following commit(s) were added to refs/heads/rc/1.3.3 by this push:
new a2d389e62af fix bug (#13589)
a2d389e62af is described below
commit a2d389e62afa447f296ed746d139d66ba332ab4c
Author: shuwenwei <[email protected]>
AuthorDate: Tue Sep 24 09:50:31 2024 +0800
fix bug (#13589)
---
.../java/org/apache/iotdb/db/storageengine/dataregion/DataRegion.java | 3 +--
1 file changed, 1 insertion(+), 2 deletions(-)
diff --git
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/DataRegion.java
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/DataRegion.java
index 90b603d0b06..8b7f919c998 100644
---
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/DataRegion.java
+++
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/DataRegion.java
@@ -868,7 +868,6 @@ public class DataRegion implements IDataRegionForQuery {
new SealedTsFileRecoverPerformer(sealedTsFile)) {
recoverPerformer.recover();
sealedTsFile.close();
- tsFileManager.add(sealedTsFile, isSeq);
tsFileResourceManager.registerSealedTsFileResource(sealedTsFile);
} catch (Throwable e) {
logger.error("Fail to recover sealed TsFile {}, skip it.",
sealedTsFile.getTsFilePath(), e);
@@ -888,10 +887,10 @@ public class DataRegion implements IDataRegionForQuery {
List<TsFileResource> resourceListForSyncRecover = new ArrayList<>();
Callable<Void> asyncRecoverTask = null;
for (TsFileResource tsFileResource : resourceList) {
+ tsFileManager.add(tsFileResource, isSeq);
if (fileTimeIndexMap.containsKey(tsFileResource.getTsFileID())) {
tsFileResource.setTimeIndex(fileTimeIndexMap.get(tsFileResource.getTsFileID()));
tsFileResource.setStatus(TsFileResourceStatus.NORMAL);
- tsFileManager.add(tsFileResource, isSeq);
resourceListForAsyncRecover.add(tsFileResource);
} else {
resourceListForSyncRecover.add(tsFileResource);