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 2017/09/29 14:08:48 UTC
[4/4] storm git commit: Merge branch 'STORM-2083' of
https://github.com/HeartSaVioR/storm into STORM-2083
Merge branch 'STORM-2083' of https://github.com/HeartSaVioR/storm into STORM-2083
STORM-2083: Blacklist scheduler
This closes #2343
This closes #1674
Project: http://git-wip-us.apache.org/repos/asf/storm/repo
Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/177cb95f
Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/177cb95f
Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/177cb95f
Branch: refs/heads/master
Commit: 177cb95f4fbcb3011f73b88d8755b577671ed527
Parents: 293643f 74cc7e2
Author: Robert Evans <ev...@yahoo-inc.com>
Authored: Fri Sep 29 08:43:52 2017 -0500
Committer: Robert Evans <ev...@yahoo-inc.com>
Committed: Fri Sep 29 08:43:52 2017 -0500
----------------------------------------------------------------------
conf/defaults.yaml | 6 +
.../src/jvm/org/apache/storm/Config.java | 6 +-
.../test/clj/org/apache/storm/nimbus_test.clj | 22 +-
storm-server/pom.xml | 2 +-
.../java/org/apache/storm/DaemonConfig.java | 59 +++-
.../org/apache/storm/daemon/nimbus/Nimbus.java | 91 +++---
.../scheduler/blacklist/BlacklistScheduler.java | 262 +++++++++++++++
.../apache/storm/scheduler/blacklist/Sets.java | 106 +++++++
.../blacklist/reporters/IReporter.java | 32 ++
.../blacklist/reporters/LogReporter.java | 41 +++
.../strategies/DefaultBlacklistStrategy.java | 172 ++++++++++
.../strategies/IBlacklistStrategy.java | 54 ++++
.../scheduler/blacklist/FaultGenerateUtils.java | 63 ++++
.../blacklist/TestBlacklistScheduler.java | 316 +++++++++++++++++++
.../TestUtilsForBlacklistScheduler.java | 263 +++++++++++++++
15 files changed, 1438 insertions(+), 57 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/storm/blob/177cb95f/conf/defaults.yaml
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/storm/blob/177cb95f/storm-server/src/main/java/org/apache/storm/DaemonConfig.java
----------------------------------------------------------------------