This is an automated email from the ASF dual-hosted git repository. haonan pushed a commit to branch speed_up_recover in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit eae6ccc31e955e7074e9794be366db362f0ec010 Author: HTHou <[email protected]> AuthorDate: Tue Jul 16 17:50:44 2024 +0800 init --- .../dataregion/tsfile/TsFileResource.java | 1 + .../tsfile/timeindex/FileTimeIndexCache.java | 18 ++++++++++-------- 2 files changed, 11 insertions(+), 8 deletions(-) diff --git a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/tsfile/TsFileResource.java b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/tsfile/TsFileResource.java index 51c7d482007..172f37d5684 100644 --- a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/tsfile/TsFileResource.java +++ b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/tsfile/TsFileResource.java @@ -229,6 +229,7 @@ public class TsFileResource { File dest = fsFactory.getFile(file + RESOURCE_SUFFIX); fsFactory.deleteIfExists(dest); fsFactory.moveFile(src, dest); + } private void serializeTo(BufferedOutputStream outputStream) throws IOException { diff --git a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/tsfile/timeindex/FileTimeIndexCache.java b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/tsfile/timeindex/FileTimeIndexCache.java index e7b4812474b..ca9118d7d78 100644 --- a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/tsfile/timeindex/FileTimeIndexCache.java +++ b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/tsfile/timeindex/FileTimeIndexCache.java @@ -19,8 +19,10 @@ package org.apache.iotdb.db.storageengine.dataregion.tsfile.timeindex; +import java.util.concurrent.TimeUnit; import org.apache.iotdb.commons.concurrent.IoTDBThreadPoolFactory; import org.apache.iotdb.commons.concurrent.ThreadName; +import org.apache.iotdb.commons.concurrent.threadpool.ScheduledExecutorUtil; import org.apache.iotdb.db.storageengine.dataregion.tsfile.TsFileResource; import java.util.concurrent.ArrayBlockingQueue; @@ -37,12 +39,12 @@ public class FileTimeIndexCache { resourceQueue.add(resource); } - public void recordTsFileResource() { - recordFileIndexThread = - IoTDBThreadPoolFactory.newSingleThreadScheduledExecutor( - ThreadName.FILE_TIMEINDEX_RECORD.getName()); - // ScheduledExecutorUtil.safelyScheduleWithFixedDelay( - // recordFileIndexThread, this::deleteOutdatedFiles, initDelayMs, periodMs, - // TimeUnit.MILLISECONDS); - } +// public void recordTsFileResource() { +// recordFileIndexThread = +// IoTDBThreadPoolFactory.newSingleThreadScheduledExecutor( +// ThreadName.FILE_TIMEINDEX_RECORD.getName()); +// ScheduledExecutorUtil.safelyScheduleWithFixedDelay( +// recordFileIndexThread, this::deleteOutdatedFiles, initDelayMs, periodMs, +// TimeUnit.MILLISECONDS); +// } }
