[incubator-iotdb] branch new_series_reader_tsfileprocessor_test updated: add log for debug

[hxd]

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

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


The following commit(s) were added to 
refs/heads/new_series_reader_tsfileprocessor_test by this push:
     new d2d4a38  add log for debug
d2d4a38 is described below

commit d2d4a3886f7f9b6fe6fbe5a8d247f5c27f0d7e4e
Author: xiangdong huang <saint...@gmail.com>
AuthorDate: Fri Feb 21 15:04:45 2020 +0800

    add log for debug
---
 .../org/apache/iotdb/db/engine/storagegroup/TsFileProcessor.java  | 4 ++--
 .../iotdb/db/engine/storagegroup/StorageGroupProcessorTest.java   | 1 +
 .../apache/iotdb/db/engine/storagegroup/TsFileProcessorTest.java  | 8 +++++++-
 3 files changed, 10 insertions(+), 3 deletions(-)

diff --git 
a/server/src/main/java/org/apache/iotdb/db/engine/storagegroup/TsFileProcessor.java
 
b/server/src/main/java/org/apache/iotdb/db/engine/storagegroup/TsFileProcessor.java
index c82751f..72ce1c7 100644
--- 
a/server/src/main/java/org/apache/iotdb/db/engine/storagegroup/TsFileProcessor.java
+++ 
b/server/src/main/java/org/apache/iotdb/db/engine/storagegroup/TsFileProcessor.java
@@ -322,7 +322,7 @@ public class TsFileProcessor {
       // is set true, we need to generate a NotifyFlushMemTable as a signal 
task and submit it to
       // the FlushManager.
       IMemTable tmpMemTable = workMemTable == null ? new NotifyFlushMemTable() 
: workMemTable;
-      if (logger.isDebugEnabled()) {
+      //if (logger.isDebugEnabled()) {
         if (tmpMemTable.isSignalMemTable()) {
           logger.error(
               "storage group {} add a signal memtable into flushing memtable 
list when async close",
@@ -331,7 +331,7 @@ public class TsFileProcessor {
           logger
               .debug("storage group {} async flush a memtable when async 
close", storageGroupName);
         }
-      }
+      //}
       try {
         addAMemtableIntoFlushingList(tmpMemTable);
       } catch (IOException e) {
diff --git 
a/server/src/test/java/org/apache/iotdb/db/engine/storagegroup/StorageGroupProcessorTest.java
 
b/server/src/test/java/org/apache/iotdb/db/engine/storagegroup/StorageGroupProcessorTest.java
index 2d179b3..fdf8c23 100644
--- 
a/server/src/test/java/org/apache/iotdb/db/engine/storagegroup/StorageGroupProcessorTest.java
+++ 
b/server/src/test/java/org/apache/iotdb/db/engine/storagegroup/StorageGroupProcessorTest.java
@@ -78,6 +78,7 @@ public class StorageGroupProcessorTest {
     EnvironmentUtils.cleanEnv();
     EnvironmentUtils.cleanDir(TestConstant.OUTPUT_DATA_DIR);
     MergeManager.getINSTANCE().stop();
+    EnvironmentUtils.cleanEnv();
   }
 
 
diff --git 
a/server/src/test/java/org/apache/iotdb/db/engine/storagegroup/TsFileProcessorTest.java
 
b/server/src/test/java/org/apache/iotdb/db/engine/storagegroup/TsFileProcessorTest.java
index 6e732b8..cf243d1 100644
--- 
a/server/src/test/java/org/apache/iotdb/db/engine/storagegroup/TsFileProcessorTest.java
+++ 
b/server/src/test/java/org/apache/iotdb/db/engine/storagegroup/TsFileProcessorTest.java
@@ -52,6 +52,8 @@ import 
org.apache.iotdb.tsfile.write.writer.RestorableTsFileIOWriter;
 import org.junit.After;
 import org.junit.Before;
 import org.junit.Test;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
 
 public class TsFileProcessorTest {
 
@@ -65,7 +67,7 @@ public class TsFileProcessorTest {
   private TSEncoding encoding = TSEncoding.RLE;
   private Map<String, String> props = Collections.emptyMap();
   private QueryContext context;
-
+  private static Logger logger = 
LoggerFactory.getLogger(TsFileProcessorTest.class);
   @Before
   public void setUp() throws Exception {
     EnvironmentUtils.envSetUp();
@@ -82,6 +84,7 @@ public class TsFileProcessorTest {
 
   @Test
   public void testWriteAndFlush() throws IOException, QueryProcessException {
+    logger.error("testWriteAndFlush begin..");
     processor = new TsFileProcessor(storageGroup, 
SystemFileFactory.INSTANCE.getFile(filePath),
         SchemaUtils.constructSchema(deviceId), 
SysTimeVersionController.INSTANCE, x -> {
     },
@@ -130,6 +133,7 @@ public class TsFileProcessorTest {
 
   @Test
   public void testWriteAndRestoreMetadata() throws IOException, 
QueryProcessException {
+    logger.error("testWriteAndRestoreMetadata begin..");
     processor = new TsFileProcessor(storageGroup, 
SystemFileFactory.INSTANCE.getFile(filePath),
         SchemaUtils.constructSchema(deviceId), 
SysTimeVersionController.INSTANCE, x -> {
     },
@@ -199,6 +203,7 @@ public class TsFileProcessorTest {
 
   @Test
   public void testMultiFlush() throws IOException, QueryProcessException {
+    logger.error("testWriteAndRestoreMetadata begin..");
     processor = new TsFileProcessor(storageGroup, 
SystemFileFactory.INSTANCE.getFile(filePath),
         SchemaUtils.constructSchema(deviceId), 
SysTimeVersionController.INSTANCE, x -> {
     },
@@ -234,6 +239,7 @@ public class TsFileProcessorTest {
 
   @Test
   public void testWriteAndClose() throws IOException, QueryProcessException {
+    logger.error("testWriteAndRestoreMetadata begin..");
     processor = new TsFileProcessor(storageGroup, 
SystemFileFactory.INSTANCE.getFile(filePath),
         SchemaUtils.constructSchema(deviceId), 
SysTimeVersionController.INSTANCE,
         unsealedTsFileProcessor -> {