Storm中有许多简单有用的命令可以用来管理拓扑,它们可以 提交、杀死、禁用、再平衡拓扑。本节就来介绍这些命令的用法。
1.提交任务
提交任务的命令格式如下:
storm jar <jar路径> <拓扑包名.拓扑类名> <拓扑名称>
例如:
storm jar storm-starter-topologies-1.0.3.jar org.apache.storm.starter.WordCountTopology MyWordCount1
2.杀死任务
杀死任务的命令格式如下:
storm kill <拓扑名称> -w 10
这里kill命令的-w参数用来指定拓扑停用以后等待的时间,单位是秒。
例如:
storm kill MyWordCount1 -w 10
3.禁用任务
禁用任务的命令格式如下:
storm deactive <拓扑名称>
例如:
storm deactive MyWordCount1
4.激活任务
激活任务的命令格式如下:
storm activate <拓扑名称>
例如:
storm activate MyWordCount1
5.再平衡任务
再平衡任务的命令格式如下:
storm rebalance <拓扑名称>
例如:
storm rebalance MyWordCount1
再平衡可以重新分配集群任务。比如,向运行中的集群增加了新的节点,使用再平衡命令将会先停用拓扑,然后在超过一定时间之后重新分配工人,并重启拓扑。











网友评论