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 <[email protected]> Authored: Fri Sep 29 08:43:52 2017 -0500 Committer: Robert Evans <[email protected]> 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 ----------------------------------------------------------------------
