标签:
在部署好Storm集群后,可以使用Storm提供的命令行客户端提供的帮助信息
[root@sc1 ~]# storm
Commands:
activate 激活指定的拓扑
classpath 获取Storm客户端运行命令时使用的类路径(classpath)
deactivate 禁用指定的拓扑
dev-zookeeper 以dev.zookeeper.path配置的值作为本地目录,以storm.zookeeper.port配置的值作为端口,启动一个新的zookeeper服务,仅用来开发测试。
drpc 启动一个drpc服务
help 查看storm的命令行帮助,输入storm时会默认启动storm help
jar 在storm集群中运行拓扑
kill 杀死集群中正在运行的拓扑,storm会先在拓扑的消息超时时间旗舰禁用Spout,以允许所有正在处理的消息完成处理。然后关闭Worker并清理它们的状态。
list 查看集群中正在运行的所有拓扑及其状态
localconfvalue 查看本地storm配置的conf-name的值
logviewer 启动logviewer守护进程
monitor
nimbus 启动storm集群的主控节点的守护进程,该守护进程与Hadoop的JobTracker类似
rebalance 重新平衡集群中正在运行的Worker。如果需要扩展Worker,当前集群中有10个节点且每个节点运行4个Worker,然后需要添加另外10个节点到集群中。这时候希望
Spout能扩散正在运行中的拓扑的Worker,让每个节点运行2个Worker。解决方法有两种,一种是杀死拓扑重新提交拓扑,一种是Storm提供的rebalance命令。
rebalance受限会在消息超时时间内禁用拓扑,使用-w可以覆盖超时时间,然后重新均衡分配集群的Worker,拓扑会返回到它原来的状态,即禁用的拓扑仍将禁用
激活的拓扑则继续运行。
remoteconfvalue 打印出远程Storm集群配置的conf-name的值,集群配置使$STORM_PATH/conf/storm.yaml与defaults.yaml合并的结果且该命令必须在集群节点上运行。
repl 打开一个包含类路径(classpath)中的jar文件和配置的Clojure REPL,方便在调试时使用。
shell 执行shell脚本
supervisor 启动Storm集群的工作节点的守护进程,该守护进程与Hadoop的TaskTracker类似。
ui 启动Storm集群的Web界面并显示集群和正在运行拓扑的详细信息。
version 查看Storm的发行版本号
Help:
help
help <command>
Documentation for the storm client can be found at http://storm.incubator.apache.org/documentation/Command-line-client.html
Configs can be overridden using one or more -c flags, e.g. "storm list -c nimbus.host=nimbus.mycompany.com"
上述描述参考Storm官方文档http://storm.apache.org/documentation/Command-line-client.html
标签:
原文地址:http://www.cnblogs.com/mengyao/p/4769865.html