kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From ewe...@apache.org
Subject kafka git commit: MINOR: Fix a variable name semantically correct.
Date Sun, 12 Jun 2016 00:17:13 GMT
Repository: kafka
Updated Branches:
  refs/heads/trunk da8517182 -> 5b88af992


MINOR: Fix a variable name semantically correct.

Hi all,
This is my first commit to Kafka.

"msec / 1000" turns into sec, isn't it?
I just have fixed a variable name.
granders

Author: kota-uchida <kota-uchida@cybozu.co.jp>

Reviewers: Guozhang Wang <wangguoz@gmail.com>, Ewen Cheslack-Postava <ewen@confluent.io>

Closes #1482 from uchan-nos/elapsed-ms


Project: http://git-wip-us.apache.org/repos/asf/kafka/repo
Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/5b88af99
Tree: http://git-wip-us.apache.org/repos/asf/kafka/tree/5b88af99
Diff: http://git-wip-us.apache.org/repos/asf/kafka/diff/5b88af99

Branch: refs/heads/trunk
Commit: 5b88af9929c12b587796ceed7d85238206131249
Parents: da85171
Author: kota-uchida <kota-uchida@cybozu.co.jp>
Authored: Sat Jun 11 17:17:06 2016 -0700
Committer: Ewen Cheslack-Postava <me@ewencp.org>
Committed: Sat Jun 11 17:17:06 2016 -0700

----------------------------------------------------------------------
 .../main/java/org/apache/kafka/tools/ThroughputThrottler.java    | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/kafka/blob/5b88af99/tools/src/main/java/org/apache/kafka/tools/ThroughputThrottler.java
----------------------------------------------------------------------
diff --git a/tools/src/main/java/org/apache/kafka/tools/ThroughputThrottler.java b/tools/src/main/java/org/apache/kafka/tools/ThroughputThrottler.java
index a58a535..68de638 100644
--- a/tools/src/main/java/org/apache/kafka/tools/ThroughputThrottler.java
+++ b/tools/src/main/java/org/apache/kafka/tools/ThroughputThrottler.java
@@ -72,8 +72,8 @@ public class ThroughputThrottler {
             return false;
         }
 
-        float elapsedMs = (sendStartMs - startMs) / 1000.f;
-        return elapsedMs > 0 && (amountSoFar / elapsedMs) > this.targetThroughput;
+        float elapsedSec = (sendStartMs - startMs) / 1000.f;
+        return elapsedSec > 0 && (amountSoFar / elapsedSec) > this.targetThroughput;
     }
 
     /**


Mime
View raw message