You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@storm.apache.org by bo...@apache.org on 2015/10/05 23:00:53 UTC
[21/37] storm git commit: correct key name
correct key name
Project: http://git-wip-us.apache.org/repos/asf/storm/repo
Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/7a0c3eee
Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/7a0c3eee
Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/7a0c3eee
Branch: refs/heads/master
Commit: 7a0c3eeeb5fbcbc5c32d47cca692cec103a68244
Parents: 6b606cf
Author: Derek Dagit <de...@yahoo-inc.com>
Authored: Fri Sep 4 12:23:06 2015 -0500
Committer: Derek Dagit <de...@yahoo-inc.com>
Committed: Fri Sep 4 12:24:43 2015 -0500
----------------------------------------------------------------------
storm-core/src/clj/backtype/storm/stats.clj | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/storm/blob/7a0c3eee/storm-core/src/clj/backtype/storm/stats.clj
----------------------------------------------------------------------
diff --git a/storm-core/src/clj/backtype/storm/stats.clj b/storm-core/src/clj/backtype/storm/stats.clj
index bf029d8..788cf41 100644
--- a/storm-core/src/clj/backtype/storm/stats.clj
+++ b/storm-core/src/clj/backtype/storm/stats.clj
@@ -958,7 +958,7 @@
(into {} (for [[id m] (:spout-id->stats acc-data)
:let [acked (:acked m)]]
[id (-> m
- (assoc :completeLatency
+ (assoc :complete-latency
(if (and acked (pos? acked))
(div (:completeLatencyTotal m)
(:acked m))