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);