You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by ja...@apache.org on 2020/11/11 01:54:18 UTC

[iotdb] branch 11Log updated: fix bug

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

jackietien pushed a commit to branch 11Log
in repository https://gitbox.apache.org/repos/asf/iotdb.git


The following commit(s) were added to refs/heads/11Log by this push:
     new 68202fa  fix bug
68202fa is described below

commit 68202fac8017173323adb69817d9df096d67f87a
Author: JackieTien97 <Ja...@foxmail.com>
AuthorDate: Wed Nov 11 09:52:05 2020 +0800

    fix bug
---
 .../org/apache/iotdb/db/engine/storagegroup/StorageGroupProcessor.java  | 2 ++
 1 file changed, 2 insertions(+)

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 0dc5bb8..424e8c9 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
@@ -560,6 +560,8 @@ public class StorageGroupProcessor {
   private void recoverTsFiles(List<TsFileResource> tsFiles, boolean isSeq) {
     for (int i = 0; i < tsFiles.size(); i++) {
       if (LevelCompactionTsFileManagement.getMergeLevel(tsFiles.get(i).getTsFile()) > 0) {
+        tsFileResource.setClosed(true);
+        tsFileManagement.add(tsFiles.get(i), isSeq);
         continue;
       }
       TsFileResource tsFileResource = tsFiles.get(i);