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 2022/01/14 02:02:08 UTC

[iotdb] branch rel/0.12 updated: [To rel/0.12][IOTDB-2320] MemoryLeak cause by wal Scheduled trim task thread (#4805)

This is an automated email from the ASF dual-hosted git repository.

haonan pushed a commit to branch rel/0.12
in repository https://gitbox.apache.org/repos/asf/iotdb.git


The following commit(s) were added to refs/heads/rel/0.12 by this push:
     new e361662  [To rel/0.12][IOTDB-2320] MemoryLeak cause by wal Scheduled trim task thread (#4805)
e361662 is described below

commit e3616623839dadb0cf8e268b05113995d834492d
Author: Heiming Choo <43...@users.noreply.github.com>
AuthorDate: Fri Jan 14 10:01:34 2022 +0800

    [To rel/0.12][IOTDB-2320] MemoryLeak cause by wal Scheduled trim task thread (#4805)
---
 .../apache/iotdb/db/engine/storagegroup/StorageGroupProcessor.java    | 4 +++-
 1 file changed, 3 insertions(+), 1 deletion(-)

diff --git a/server/src/main/java/org/apache/iotdb/db/engine/storagegroup/StorageGroupProcessor.java b/server/src/main/java/org/apache/iotdb/db/engine/storagegroup/StorageGroupProcessor.java
index 53eca34..f7b5af8 100755
--- a/server/src/main/java/org/apache/iotdb/db/engine/storagegroup/StorageGroupProcessor.java
+++ b/server/src/main/java/org/apache/iotdb/db/engine/storagegroup/StorageGroupProcessor.java
@@ -396,6 +396,9 @@ public class StorageGroupProcessor {
                 virtualStorageGroupId,
                 storageGroupSysDir.getAbsolutePath());
 
+    // recover tsfiles
+    recover();
+    // start trim task at last
     ScheduledExecutorService executorService =
         IoTDBThreadPoolFactory.newSingleThreadScheduledExecutor(
             String.format("WAL-trimTask-%s/%s", logicalStorageGroupName, virtualStorageGroupId));
@@ -404,7 +407,6 @@ public class StorageGroupProcessor {
         config.getWalPoolTrimIntervalInMS(),
         config.getWalPoolTrimIntervalInMS(),
         TimeUnit.MILLISECONDS);
-    recover();
   }
 
   public String getLogicalStorageGroupName() {