[iotdb] branch pipeline_flush_task updated: change time

[jackietien]

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

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


The following commit(s) were added to refs/heads/pipeline_flush_task by this 
push:
     new e6400e7  change time
e6400e7 is described below

commit e6400e7efcfc8aae79ea6088dd58e0deac945a2d
Author: JackieTien97 <jackiet...@foxmail.com>
AuthorDate: Wed Jan 27 09:32:49 2021 +0800

    change time
---
 .../main/java/org/apache/iotdb/db/engine/flush/MemTableFlushTask.java | 4 ++--
 1 file changed, 2 insertions(+), 2 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 8030ce8..b64fd8f 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
@@ -195,13 +195,13 @@ public class MemTableFlushTask {
           if (task instanceof StartFlushGroupIOTask || task instanceof 
EndChunkGroupIoTask) {
             ioTaskQueue.add(task);
           } else {
-            long starTime = System.currentTimeMillis();
             Pair<TVList, MeasurementSchema> encodingMessage = (Pair<TVList, 
MeasurementSchema>) task;
+            long starTime = System.currentTimeMillis();
             IChunkWriter seriesWriter = new 
ChunkWriterImpl(encodingMessage.right);
             writeOneSeries(encodingMessage.left, seriesWriter, 
encodingMessage.right.getType());
             seriesWriter.sealCurrentPage();
             seriesWriter.clearPageWriter();
-            memSerializeTime += System.currentTimeMillis() - starTime;
+            memSerializeTime += (System.currentTimeMillis() - starTime);
             ioTaskQueue.add(seriesWriter);
           }
         }