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 <[email protected]> Reviewers: Guozhang Wang <[email protected]>, Ewen Cheslack-Postava <[email protected]> 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 <[email protected]> Authored: Sat Jun 11 17:17:06 2016 -0700 Committer: Ewen Cheslack-Postava <[email protected]> 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; } /**
