You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by ja...@apache.org on 2021/01/27 01:33:11 UTC
[iotdb] branch pipeline_flush_task updated: change time
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 <Ja...@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);
}
}