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 <[email protected]> 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); } }
