You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by ew...@apache.org on 2016/06/12 00:17:13 UTC
kafka git commit: MINOR: Fix a variable name semantically correct.
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 <ko...@cybozu.co.jp>
Reviewers: Guozhang Wang <wa...@gmail.com>, Ewen Cheslack-Postava <ew...@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 <ko...@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;
}
/**