[iotdb] branch draft_serial_flush_task updated: delete some useless code

[jackietien]

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

jackietien pushed a commit to branch draft_serial_flush_task
in repository https://gitbox.apache.org/repos/asf/iotdb.git


The following commit(s) were added to refs/heads/draft_serial_flush_task by 
this push:
     new 581cb65  delete some useless code
581cb65 is described below

commit 581cb654e020337fc509d3e53a2e020a429f61fc
Author: JackieTien97 <jackiet...@foxmail.com>
AuthorDate: Tue Jan 26 19:14:58 2021 +0800

    delete some useless code
---
 .../org/apache/iotdb/db/engine/flush/MemTableFlushTask.java   | 11 -----------
 1 file changed, 11 deletions(-)

diff --git 
a/server/src/main/java/org/apache/iotdb/db/engine/flush/MemTableFlushTask.java 
b/server/src/main/java/org/apache/iotdb/db/engine/flush/MemTableFlushTask.java
index 3f1a128..155110d 100644
--- 
a/server/src/main/java/org/apache/iotdb/db/engine/flush/MemTableFlushTask.java
+++ 
b/server/src/main/java/org/apache/iotdb/db/engine/flush/MemTableFlushTask.java
@@ -26,7 +26,6 @@ import java.util.concurrent.ConcurrentLinkedQueue;
 import java.util.concurrent.ExecutionException;
 import java.util.concurrent.Future;
 import java.util.concurrent.TimeUnit;
-import java.util.concurrent.atomic.AtomicLong;
 import org.apache.iotdb.db.engine.flush.pool.FlushSubTaskPoolManager;
 import org.apache.iotdb.db.engine.memtable.IMemTable;
 import org.apache.iotdb.db.engine.memtable.IWritableMemChunk;
@@ -82,8 +81,6 @@ public class MemTableFlushTask {
         storageGroup, memTable.memSize(),
         memTable.getTotalPointsNum() / memTable.getSeriesNumber());
     long start = System.currentTimeMillis();
-    long sortTime = 0L;
-    long memSerializeTime = 0L;
 
     Set<Entry<String, Map<String, IWritableMemChunk>>> ite = 
memTable.getMemTableMap().entrySet();
     try {
@@ -92,18 +89,14 @@ public class MemTableFlushTask {
         this.writer.startChunkGroup(memTableEntry.getKey());
         final Map<String, IWritableMemChunk> value = memTableEntry.getValue();
         for (Entry<String, IWritableMemChunk> iWritableMemChunkEntry : 
value.entrySet()) {
-          long startTime = System.currentTimeMillis();
           IWritableMemChunk series = iWritableMemChunkEntry.getValue();
           MeasurementSchema desc = series.getSchema();
           TVList tvList = series.getSortedTVListForFlush();
-          sortTime += (System.currentTimeMillis() - startTime);
 
           //start flush
-          long starTime = System.currentTimeMillis();
           IChunkWriter seriesWriter = new ChunkWriterImpl(desc);
           writeOneSeries(tvList, seriesWriter, desc.getType());
           seriesWriter.writeToFileWriter(this.writer);
-          memSerializeTime += (System.currentTimeMillis() - starTime);
         }
         this.writer.setMinPlanIndex(memTable.getMinPlanIndex());
         this.writer.setMaxPlanIndex(memTable.getMaxPlanIndex());
@@ -117,10 +110,6 @@ public class MemTableFlushTask {
           memTable.getVersion(), e);
       throw new FlushRunTimeException(e);
     }
-    noMoreEncodingTask = true;
-    LOGGER.debug(
-        "Storage group {} memtable {}, flushing into disk: data sort time cost 
{} ms.",
-        storageGroup, memTable.getVersion(), sortTime);
     LOGGER.info(
         "Storage group {} memtable {} flushing a memtable has finished! Time 
consumption: {}ms",
         storageGroup, memTable, System.currentTimeMillis() - start);