You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by ji...@apache.org on 2019/06/25 02:07:17 UTC

[incubator-iotdb] branch feature_async_close_tsfile updated: add flush thread name in flush task

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

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


The following commit(s) were added to refs/heads/feature_async_close_tsfile by this push:
     new 4e01d3b  add flush thread name in flush task
     new 04017f0  Merge branch 'feature_async_close_tsfile' of github.com:apache/incubator-iotdb into feature_async_close_tsfile
4e01d3b is described below

commit 4e01d3bed0ddc86dd4294c032d41bd575f473198
Author: 江天 <jt...@163.com>
AuthorDate: Tue Jun 25 10:02:08 2019 +0800

    add flush thread name in flush task
---
 .../java/org/apache/iotdb/db/engine/memtable/MemTableFlushTaskV2.java | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git a/iotdb/src/main/java/org/apache/iotdb/db/engine/memtable/MemTableFlushTaskV2.java b/iotdb/src/main/java/org/apache/iotdb/db/engine/memtable/MemTableFlushTaskV2.java
index 29e6ed3..68b3b6f 100644
--- a/iotdb/src/main/java/org/apache/iotdb/db/engine/memtable/MemTableFlushTaskV2.java
+++ b/iotdb/src/main/java/org/apache/iotdb/db/engine/memtable/MemTableFlushTaskV2.java
@@ -93,7 +93,7 @@ public class MemTableFlushTaskV2 {
     }
     LOGGER.info("Storage group {}, flushing a memtable into disk: serialize data into mem cost {} ms.",
         storageGroup, memSerializeTime);
-  });
+  }, Thread.currentThread().getName() + "memFLush");
 
 
   //TODO a better way is: for each TsFile, assign it a Executors.singleThreadPool,
@@ -129,7 +129,7 @@ public class MemTableFlushTaskV2 {
       }
     }
     LOGGER.info("flushing a memtable in storage group {}, cost {}ms", storageGroup, ioTime);
-  });
+  }, Thread.currentThread().getName() + "ioFLush");
 
 
   private void writeOneSeries(List<TimeValuePair> tvPairs, IChunkWriter seriesWriterImpl,