You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by ha...@apache.org on 2024/09/05 07:02:49 UTC
(iotdb) branch clearAsyncTsFileResourceRecoverTaskList created (now 97b081beb47)
This is an automated email from the ASF dual-hosted git repository.
haonan pushed a change to branch clearAsyncTsFileResourceRecoverTaskList
in repository https://gitbox.apache.org/repos/asf/iotdb.git
at 97b081beb47 clear AsyncTsFileResourceRecoverTaskList after data region recoverd
This branch includes the following new commits:
new 97b081beb47 clear AsyncTsFileResourceRecoverTaskList after data region recoverd
The 1 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
(iotdb) 01/01: clear AsyncTsFileResourceRecoverTaskList after data region recoverd
Posted by ha...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
haonan pushed a commit to branch clearAsyncTsFileResourceRecoverTaskList
in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit 97b081beb47c400818269ee9b38105b209a2234a
Author: HTHou <hh...@outlook.com>
AuthorDate: Thu Sep 5 15:02:18 2024 +0800
clear AsyncTsFileResourceRecoverTaskList after data region recoverd
---
.../main/java/org/apache/iotdb/db/storageengine/StorageEngine.java | 1 +
.../java/org/apache/iotdb/db/storageengine/dataregion/DataRegion.java | 4 ++++
2 files changed, 5 insertions(+)
diff --git a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/StorageEngine.java b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/StorageEngine.java
index 11b2a1c6c63..fa8241e4403 100644
--- a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/StorageEngine.java
+++ b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/StorageEngine.java
@@ -366,6 +366,7 @@ public class StorageEngine implements IService {
for (Callable<Void> task : asyncTsFileResourceRecoverTasks) {
task.call();
}
+ dataRegion.clearAsyncTsFileResourceRecoverTaskList();
dataRegion.initCompactionSchedule();
return null;
};
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 09b30bf1bb6..65bd32095f2 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
@@ -398,6 +398,10 @@ public class DataRegion implements IDataRegionForQuery {
return asyncTsFileResourceRecoverTaskList;
}
+ public void clearAsyncTsFileResourceRecoverTaskList() {
+ asyncTsFileResourceRecoverTaskList.clear();
+ }
+
/** this class is used to store recovering context. */
private class DataRegionRecoveryContext {