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/07/17 02:02:10 UTC

[incubator-iotdb] branch dev_merge updated: fix statistic time unit

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

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


The following commit(s) were added to refs/heads/dev_merge by this push:
     new 80ba624  fix statistic time unit
80ba624 is described below

commit 80ba6241a18b67e16b8035387e802b8b6d452362
Author: 江天 <jt...@163.com>
AuthorDate: Wed Jul 17 09:59:45 2019 +0800

    fix statistic time unit
---
 .../src/main/java/org/apache/iotdb/db/engine/merge/MergeTask.java | 8 ++++----
 1 file changed, 4 insertions(+), 4 deletions(-)

diff --git a/iotdb/src/main/java/org/apache/iotdb/db/engine/merge/MergeTask.java b/iotdb/src/main/java/org/apache/iotdb/db/engine/merge/MergeTask.java
index 6244f10..d6fab3f 100644
--- a/iotdb/src/main/java/org/apache/iotdb/db/engine/merge/MergeTask.java
+++ b/iotdb/src/main/java/org/apache/iotdb/db/engine/merge/MergeTask.java
@@ -156,10 +156,10 @@ public class MergeTask implements Callable<Void> {
     cleanUp(true);
     if (logger.isInfoEnabled()) {
       double elapsedTime = (double) (System.currentTimeMillis() - startTime);
-      double byteRate = totalFileSize / elapsedTime / 1024;
-      double seriesRate = unmergedSeries.size() / elapsedTime;
-      double chunkRate = totalChunkWritten / elapsedTime;
-      double fileRate = (seqFiles.size() + unseqFiles.size()) / elapsedTime;
+      double byteRate = totalFileSize / elapsedTime / 1024 / 1024 * 1000;
+      double seriesRate = unmergedSeries.size() / elapsedTime * 1000;
+      double chunkRate = totalChunkWritten / elapsedTime * 1000;
+      double fileRate = (seqFiles.size() + unseqFiles.size()) / elapsedTime * 1000;
       logger.info("{} ends after {}ms, byteRate: {}MB/s, seriesRate {}/s, chunkRate: {}/s, "
               + "fileRate: {}/s",
           taskName, elapsedTime, byteRate, seriesRate, chunkRate, fileRate);