You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@storm.apache.org by zh...@apache.org on 2016/02/26 00:13:58 UTC
[3/7] storm git commit: change to removeBackpressure (java version)
change to removeBackpressure (java version)
Project: http://git-wip-us.apache.org/repos/asf/storm/repo
Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/a1ef75f6
Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/a1ef75f6
Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/a1ef75f6
Branch: refs/heads/master
Commit: a1ef75f693a78de0c6952aadf4bdf2b2ebbef97e
Parents: 03f710c
Author: zhuol <zh...@yahoo-inc.com>
Authored: Wed Feb 24 19:45:42 2016 -0600
Committer: zhuol <zh...@yahoo-inc.com>
Committed: Wed Feb 24 19:45:42 2016 -0600
----------------------------------------------------------------------
storm-core/src/clj/org/apache/storm/daemon/nimbus.clj | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/storm/blob/a1ef75f6/storm-core/src/clj/org/apache/storm/daemon/nimbus.clj
----------------------------------------------------------------------
diff --git a/storm-core/src/clj/org/apache/storm/daemon/nimbus.clj b/storm-core/src/clj/org/apache/storm/daemon/nimbus.clj
index 58cf61c..ed26a79 100644
--- a/storm-core/src/clj/org/apache/storm/daemon/nimbus.clj
+++ b/storm-core/src/clj/org/apache/storm/daemon/nimbus.clj
@@ -1598,7 +1598,7 @@
(transition-name! nimbus storm-name [:kill wait-amt] true)
(notify-topology-action-listener nimbus storm-name operation))
(if (topology-conf TOPOLOGY-BACKPRESSURE-ENABLE)
- (.remove-backpressure! (:storm-cluster-state nimbus) storm-id))
+ (.removeBackpressure (:storm-cluster-state nimbus) storm-id))
(add-topology-to-history-log (get-storm-id (:storm-cluster-state nimbus) storm-name)
nimbus topology-conf)))