[incubator-iotdb] branch dev_TTL updated: fix default ttl not effective change log level

[jiangtian]

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

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


The following commit(s) were added to refs/heads/dev_TTL by this push:
     new c5f2dcb  fix default ttl not effective change log level
c5f2dcb is described below

commit c5f2dcb4190012a654e5f3625a554d2170049452
Author: jt <jt2594...@163.com>
AuthorDate: Tue Sep 24 10:09:15 2019 +0800

    fix default ttl not effective
    change log level
---
 server/src/main/java/org/apache/iotdb/db/engine/StorageEngine.java  | 1 +
 .../apache/iotdb/db/engine/storagegroup/StorageGroupProcessor.java  | 6 +++---
 2 files changed, 4 insertions(+), 3 deletions(-)

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 5885c2b..f850d60 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
@@ -159,6 +159,7 @@ public class StorageEngine implements IService {
             logger.info("construct a processor instance, the storage group is 
{}, Thread is {}",
                 storageGroupName, Thread.currentThread().getId());
             processor = new StorageGroupProcessor(systemDir, storageGroupName);
+            
processor.setDataTTL(MManager.getInstance().getNodeByPathFromCache(storageGroupName).getDataTTL());
             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 74673fa..27b95d3 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
@@ -591,12 +591,12 @@ public class StorageGroupProcessor {
 
   public synchronized void checkFilesTTL() {
     if (dataTTL == Long.MAX_VALUE) {
-      logger.info("{}: TTL not set, ignore the check", storageGroupName);
+      logger.debug("{}: TTL not set, ignore the check", storageGroupName);
       return;
     }
     long timeBound = System.currentTimeMillis() - dataTTL;
-    if (logger.isInfoEnabled()) {
-      logger.info("{}: TTL removing files before {}", storageGroupName, new 
Date(timeBound));
+    if (logger.isDebugEnabled()) {
+      logger.debug("{}: TTL removing files before {}", storageGroupName, new 
Date(timeBound));
     }
     try {
       for (TsFileResource tsFileResource : unSequenceFileList) {