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 2016/03/22 20:57:46 UTC

[4/4] storm git commit: Merge branch 'STORM-1614_backpressure_init_and_cleanup_changes' of https://github.com/abellina/storm into STORM-1614

Merge branch 'STORM-1614_backpressure_init_and_cleanup_changes' of https://github.com/abellina/storm into STORM-1614

STORM-1614: backpressure changes and test


Project: http://git-wip-us.apache.org/repos/asf/storm/repo
Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/e675f771
Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/e675f771
Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/e675f771

Branch: refs/heads/master
Commit: e675f771c0b601e6ffdde1ecc20a3699c42d754a
Parents: 0b3ee90 092ea1d
Author: Robert (Bobby) Evans <ev...@yahoo-inc.com>
Authored: Tue Mar 22 14:47:43 2016 -0500
Committer: Robert (Bobby) Evans <ev...@yahoo-inc.com>
Committed: Tue Mar 22 14:47:43 2016 -0500

----------------------------------------------------------------------
 .../src/clj/org/apache/storm/daemon/nimbus.clj  |  16 ++-
 .../src/clj/org/apache/storm/daemon/worker.clj  |   1 +
 .../storm/cluster/IStormClusterState.java       |   2 +
 .../storm/cluster/StormClusterStateImpl.java    |  33 ++++-
 .../test/clj/org/apache/storm/nimbus_test.clj   | 133 ++++++++++++++++++-
 .../cluster/StormClusterStateImplTest.java      | 116 ++++++++++++++++
 6 files changed, 287 insertions(+), 14 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/storm/blob/e675f771/storm-core/src/clj/org/apache/storm/daemon/nimbus.clj
----------------------------------------------------------------------

http://git-wip-us.apache.org/repos/asf/storm/blob/e675f771/storm-core/src/clj/org/apache/storm/daemon/worker.clj
----------------------------------------------------------------------

http://git-wip-us.apache.org/repos/asf/storm/blob/e675f771/storm-core/test/clj/org/apache/storm/nimbus_test.clj
----------------------------------------------------------------------