Repository: storm Updated Branches: refs/heads/master 265ff91a7 -> f47246557
Fixing Plus thingy. Project: http://git-wip-us.apache.org/repos/asf/storm/repo Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/747080e0 Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/747080e0 Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/747080e0 Branch: refs/heads/master Commit: 747080e08af0bd46624e53264111cc3be1a0a74f Parents: 265ff91 Author: Kyle Nusbaum <[email protected]> Authored: Thu Feb 11 16:17:20 2016 -0600 Committer: Kyle Nusbaum <[email protected]> Committed: Thu Feb 11 16:17:20 2016 -0600 ---------------------------------------------------------------------- storm-core/src/clj/org/apache/storm/stats.clj | 14 +++++++------- 1 file changed, 7 insertions(+), 7 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/storm/blob/747080e0/storm-core/src/clj/org/apache/storm/stats.clj ---------------------------------------------------------------------- diff --git a/storm-core/src/clj/org/apache/storm/stats.clj b/storm-core/src/clj/org/apache/storm/stats.clj index 4f25f53..8b37fc3 100644 --- a/storm-core/src/clj/org/apache/storm/stats.clj +++ b/storm-core/src/clj/org/apache/storm/stats.clj @@ -561,27 +561,27 @@ (get window) handle-sys-components-fn vals - (reduce +)) + (#(reduce + %))) :transferred (-> statk->w->sid->num :transferred str-key (get window) handle-sys-components-fn vals - (reduce +)) + (#(reduce + %))) :capacity (compute-agg-capacity statk->w->sid->num uptime) :acked (-> statk->w->sid->num :acked str-key (get window) vals - (reduce +)) + (#(reduce + %))) :failed (-> statk->w->sid->num :failed str-key (get window) vals - (reduce +))})})) + (#(reduce + %)))})})) (defn agg-pre-merge-topo-page-spout [{comp-id :comp-id @@ -610,20 +610,20 @@ (get window) handle-sys-components-fn vals - (reduce +)) + (#(reduce + %))) :transferred (-> statk->w->sid->num :transferred str-key (get window) handle-sys-components-fn vals - (reduce +)) + (#(reduce + %))) :failed (-> statk->w->sid->num :failed str-key (get window) vals - (reduce +))})})) + (#(reduce + %)))})})) (defn merge-agg-comp-stats-comp-page-bolt [{acc-in :cid+sid->input-stats
