Repository: storm Updated Branches: refs/heads/master bd396b3a4 -> dd00bc0a2
Improvment Kafka Spout Time Metric Project: http://git-wip-us.apache.org/repos/asf/storm/repo Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/27373bae Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/27373bae Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/27373bae Branch: refs/heads/master Commit: 27373baee746f7baba2a60e06054590afd687976 Parents: 58050a5 Author: darionyaphet <[email protected]> Authored: Tue Feb 23 23:20:29 2016 +0800 Committer: darionyaphet <[email protected]> Committed: Tue Feb 23 23:20:29 2016 +0800 ---------------------------------------------------------------------- .../src/jvm/org/apache/storm/kafka/PartitionManager.java | 5 ++--- 1 file changed, 2 insertions(+), 3 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/storm/blob/27373bae/external/storm-kafka/src/jvm/org/apache/storm/kafka/PartitionManager.java ---------------------------------------------------------------------- diff --git a/external/storm-kafka/src/jvm/org/apache/storm/kafka/PartitionManager.java b/external/storm-kafka/src/jvm/org/apache/storm/kafka/PartitionManager.java index dbf70a0..9d78fdc 100644 --- a/external/storm-kafka/src/jvm/org/apache/storm/kafka/PartitionManager.java +++ b/external/storm-kafka/src/jvm/org/apache/storm/kafka/PartitionManager.java @@ -170,7 +170,7 @@ public class PartitionManager { private void fill() { - long start = System.nanoTime(); + long start = System.currentTimeMillis(); Long offset; // Are there failed tuples? If so, fetch those first. @@ -205,8 +205,7 @@ public class PartitionManager { return; } - long end = System.nanoTime(); - long millis = (end - start) / 1000000; + long millis = System.currentTimeMillis() - start; _fetchAPILatencyMax.update(millis); _fetchAPILatencyMean.update(millis); _fetchAPICallCount.incr();
