[incubator-iotdb] 01/02: add flush and close log in StorageGroupProcessor

[qi...@apache.org]

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

qiaojialin pushed a commit to branch improve_log
in repository https://gitbox.apache.org/repos/asf/incubator-iotdb.git

commit 1776c30a733b7257aac70a9f6fc2916ba637d732
Author: qiaojialin <64...@qq.com>
AuthorDate: Sat Sep 21 18:33:55 2019 +0800

    add flush and close log in StorageGroupProcessor
---
 server/src/main/java/org/apache/iotdb/db/engine/StorageEngine.java      | 2 +-
 .../org/apache/iotdb/db/engine/storagegroup/StorageGroupProcessor.java  | 2 ++
 2 files changed, 3 insertions(+), 1 deletion(-)

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 fc11c68..837b504 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
@@ -126,7 +126,7 @@ public class StorageEngine implements IService {
         synchronized (storageGroupName) {
           processor = processorMap.get(storageGroupName);
           if (processor == null) {
-            logger.debug("construct a processor instance, the storage group is {}, Thread is {}",
+            logger.info("construct a processor instance, the storage group is {}, Thread is {}",
                 storageGroupName, Thread.currentThread().getId());
             processor = new StorageGroupProcessor(systemDir, storageGroupName);
             processorMap.put(storageGroupName, processor);
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 ddac211..f6f2fe8 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
@@ -516,10 +516,12 @@ public class StorageGroupProcessor {
       updateEndTimeMap(workSequenceTsFileProcessor);
       workSequenceTsFileProcessor.asyncClose();
       workSequenceTsFileProcessor = null;
+      logger.info("close a sequence tsfile processor {}", storageGroupName);
     } else {
       closingUnSequenceTsFileProcessor.add(workUnSequenceTsFileProcessor);
       workUnSequenceTsFileProcessor.asyncClose();
       workUnSequenceTsFileProcessor = null;
+      logger.info("close an unsequence tsfile processor {}", storageGroupName);
     }
   }