You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@storm.apache.org by ka...@apache.org on 2016/08/31 09:37:06 UTC
[4/6] storm git commit: STORM-2039: no need to wrap the backpressure
function in another function
STORM-2039: no need to wrap the backpressure function in another function
Project: http://git-wip-us.apache.org/repos/asf/storm/repo
Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/c924c0e7
Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/c924c0e7
Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/c924c0e7
Branch: refs/heads/1.0.x-branch
Commit: c924c0e718b89c2a3bbe20dd03659005aafa5430
Parents: 17c2395
Author: Alessandro Bellina <ab...@yahoo-inc.com>
Authored: Wed Aug 17 08:05:40 2016 -0500
Committer: Jungtaek Lim <ka...@gmail.com>
Committed: Wed Aug 31 18:32:09 2016 +0900
----------------------------------------------------------------------
storm-core/src/clj/org/apache/storm/daemon/worker.clj | 4 +---
1 file changed, 1 insertion(+), 3 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/storm/blob/c924c0e7/storm-core/src/clj/org/apache/storm/daemon/worker.clj
----------------------------------------------------------------------
diff --git a/storm-core/src/clj/org/apache/storm/daemon/worker.clj b/storm-core/src/clj/org/apache/storm/daemon/worker.clj
index fd3cf61..6a0ff38 100644
--- a/storm-core/src/clj/org/apache/storm/daemon/worker.clj
+++ b/storm-core/src/clj/org/apache/storm/daemon/worker.clj
@@ -738,9 +738,7 @@
(check-credentials-changed)))
(if ((:storm-conf worker) TOPOLOGY-BACKPRESSURE-ENABLE)
- (schedule-recurring (:refresh-backpressure-timer worker) 0 (conf TASK-BACKPRESSURE-POLL-SECS)
- (fn []
- (topology-backpressure-callback))))
+ (schedule-recurring (:refresh-backpressure-timer worker) 0 (conf TASK-BACKPRESSURE-POLL-SECS) topology-backpressure-callback))
;; The jitter allows the clients to get the data at different times, and avoids thundering herd
(when-not (.get conf TOPOLOGY-DISABLE-LOADAWARE-MESSAGING)