This is an automated email from the ASF dual-hosted git repository. heiming pushed a commit to branch tiered_storage in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit 024cc1b4c8d003b971f2cfb3111b2e20b99f9c0b Author: HeimingZ <[email protected]> AuthorDate: Wed May 24 16:42:56 2023 +0800 add cache recover --- .../main/java/org/apache/iotdb/db/engine/StorageEngine.java | 10 ++++++++++ 1 file changed, 10 insertions(+) diff --git a/server/src/main/java/org/apache/iotdb/db/engine/StorageEngine.java b/server/src/main/java/org/apache/iotdb/db/engine/StorageEngine.java index 0021dcfa6f1..c122b79c444 100644 --- a/server/src/main/java/org/apache/iotdb/db/engine/StorageEngine.java +++ b/server/src/main/java/org/apache/iotdb/db/engine/StorageEngine.java @@ -63,6 +63,7 @@ import org.apache.iotdb.db.utils.UpgradeUtils; import org.apache.iotdb.db.wal.WALManager; import org.apache.iotdb.db.wal.exception.WALException; import org.apache.iotdb.db.wal.recover.WALRecoverManager; +import org.apache.iotdb.os.cache.CacheRecoverTask; import org.apache.iotdb.rpc.RpcUtils; import org.apache.iotdb.rpc.TSStatusCode; import org.apache.iotdb.tsfile.exception.write.PageException; @@ -273,6 +274,15 @@ public class StorageEngine implements IService { futures.add(cachedThreadPool.submit(recoverDataRegionTask)); } } + // submit object storage cache recover task + if (config.isEnableObjectStorage()) { + futures.add( + cachedThreadPool.submit( + () -> { + new CacheRecoverTask().run(); + return null; + })); + } } /** get StorageGroup -> DataRegionIdList map from data/system directory. */
