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:20 UTC
[2/5] storm git commit: STORM-2039: make :backpressure-trigger an
Object instead of an atom
STORM-2039: make :backpressure-trigger an Object instead of an atom
Project: http://git-wip-us.apache.org/repos/asf/storm/repo
Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/96b3325c
Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/96b3325c
Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/96b3325c
Branch: refs/heads/master
Commit: 96b3325ccdf7ac7649a1425d176c59308811954c
Parents: 820c268
Author: Alessandro Bellina <ab...@yahoo-inc.com>
Authored: Tue Aug 16 21:23:19 2016 -0500
Committer: Alessandro Bellina <ab...@yahoo-inc.com>
Committed: Tue Aug 16 22:59:56 2016 -0500
----------------------------------------------------------------------
storm-core/src/clj/org/apache/storm/daemon/worker.clj | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/storm/blob/96b3325c/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 0c4cc46..2b6843c 100644
--- a/storm-core/src/clj/org/apache/storm/daemon/worker.clj
+++ b/storm-core/src/clj/org/apache/storm/daemon/worker.clj
@@ -331,7 +331,7 @@
:load-mapping (LoadMapping.)
:assignment-versions assignment-versions
:backpressure (AtomicBoolean. false) ;; whether this worker is going slow
- :backpressure-trigger (AtomicBoolean. false) ;; a trigger for synchronization with executors
+ :backpressure-trigger (Object.) ;; a trigger for synchronization with executors
:throttle-on (AtomicBoolean. false) ;; whether throttle is activated for spouts
)))