Update commands in binary files
Project: http://git-wip-us.apache.org/repos/asf/storm/repo Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/2d4ad6f4 Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/2d4ad6f4 Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/2d4ad6f4 Branch: refs/heads/master Commit: 2d4ad6f4655ff56057d50f359394ecd01fde43eb Parents: 93b314c Author: Abhishek Agarwal <[email protected]> Authored: Mon Feb 22 16:48:28 2016 +0530 Committer: Abhishek Agarwal <[email protected]> Committed: Mon Feb 22 16:48:28 2016 +0530 ---------------------------------------------------------------------- bin/storm.cmd | 2 +- bin/storm.py | 6 +++--- 2 files changed, 4 insertions(+), 4 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/storm/blob/2d4ad6f4/bin/storm.cmd ---------------------------------------------------------------------- diff --git a/bin/storm.cmd b/bin/storm.cmd index ff3b246..1ef1e42 100644 --- a/bin/storm.cmd +++ b/bin/storm.cmd @@ -194,7 +194,7 @@ goto :eof :rebalance - set CLASS=org.apache.storm.command.rebalance + set CLASS=org.apache.storm.command.Rebalance set STORM_OPTS=%STORM_CLIENT_OPTS% %STORM_OPTS% goto :eof http://git-wip-us.apache.org/repos/asf/storm/blob/2d4ad6f4/bin/storm.py ---------------------------------------------------------------------- diff --git a/bin/storm.py b/bin/storm.py index acbfe7b..94d6143 100755 --- a/bin/storm.py +++ b/bin/storm.py @@ -378,7 +378,7 @@ def set_log_level(*args): Clears settings, resetting back to the original level """ exec_storm_class( - "org.apache.storm.command.set_log_level", + "org.apache.storm.command.SetLogLevel", args=args, jvmtype="-client", extrajars=[USER_CONF_DIR, STORM_BIN_DIR]) @@ -433,7 +433,7 @@ def rebalance(*args): print_usage(command="rebalance") sys.exit(2) exec_storm_class( - "org.apache.storm.command.rebalance", + "org.apache.storm.command.Rebalance", args=args, jvmtype="-client", extrajars=[USER_CONF_DIR, STORM_BIN_DIR]) @@ -685,7 +685,7 @@ def monitor(*args): watch-item is 'emitted'; """ exec_storm_class( - "org.apache.storm.command.monitor", + "org.apache.storm.command.Monitor", args=args, jvmtype="-client", extrajars=[USER_CONF_DIR, STORM_BIN_DIR])
