Commands: activate classpath deactivate dev-zookeeper drpc help jar kill list localconfvalue logviewer monitor nimbus rebalance remoteconfvalue repl shell supervisor ui upload-credentials version Help: help help <command>
1.jar shell
提交topology任务命令:
并发
storm jar topology-jar-path class ...
2.kill ui
杀死topology任务
spa
storm kill topology-name [-w wait-time-secs] -w 等待多少秒后杀死
3.nimbus 命令行
启动nimbus守护进程
线程
storm nimbus
4.supervisor日志
启动supervisor守护进程
code
storm supervisor
5.uicomponent
启动ui守护进程
orm
storm ui
6.drpc
启动drpc守护进程
storm drpc
7.logviewer
提供一个Web接口查看Storm日志文件,在storm ui上就能够观看
storm logviewer
8.list
列出正在运行的拓扑及其状态
storm list
1.rebalance
平衡即动态设置拓扑的进程数量和线程数量等
storm rebalance topology-name [-w wait-time-secs] [-n new-num-workers] [-e component=parallelist]
注意:
通过试验发现, storm rebalance topology-name -n 调整worker数没有问题。
但在调整topology中某个spout或bolt的并行数时,有时候并不能生效。
如 storm rebalance topology-name -e bolt1=3 命令有时候会不生效。
通过进一步分析发现,“-e bolt1=3”, 能够用于减少bolt1的并发度,但并不能增大其并发度。
也就说若是默认bolt1的并发度为5(在建立topology时设定),那么咱们能够用“-e bolt1=4”将其并发度减少为4,但并不能使用“-e bolt1=6”将其并发发度调整为6。
“-e bolt1=6”命令的状况是:若是当前bolt1的并发度为5,则什么也作;若是bolt1当前的并发度小于5,将其调整为5。
1.activate
激活指定的topology的spout:语法以下
storm activate topology-name
2.deactivate
禁用指定的topology的spout:语法以下
storm deactivate topology-name
3.classpath
打印storm运行时的路径:语法以下
storm classpath
4.help
帮助命令:语法以下
storm help <command>
5.localconfvalue
打印本地storm的配置文件,输出内容是storm.yaml和defaults.yaml的合并内容:语法以下
storm localconfvalue conf-name
6.remoteconfvalue
打印本地storm的配置文件,输出内容是storm.yaml和defaults.yaml的合并内容 这个必须在集群模式下才会有效:
storm remoteconfvalue conf-name
7. version
storm版本输出:
storm version