jstorm操作命令
程序员文章站
2022-07-13 15:45:55
...
启动ZOOPKEEPER
zkServer.sh start
启动NIMBUS
jstorm nimbus &
启动SUPERVISOR
jstorm supervisor &
启动UI
jstorm ui &
部署TOPOLOGY
jstorm jar /opt/hadoop/loganalyst/storm-dependend/data/teststorm-1.0.jar teststorm.TopologyMain /opt/hadoop/loganalyst/storm-dependend/data/words.txt
删除TOPOLOGY
jstorm kill {toponame}
激活TOPOLOGY
jstorm active {toponame}
不激活TOPOLOGY
jstorm deactive {toponame}
列出所有TOPOLOGY
jstorm list
--------------------------------------------------------------------------------------------------
activate
classpath
deactivate
drpc
help
jar
kill
list
localconfvalue
metricsMonitor
nimbus
rebalance
remoteconfvalue
restart
supervisor
update_topology
zktool
[--config client_storm.yaml] optional, setting client's storm.yaml
[--exclude-jars exclude1.jar,exclude2.jar] optional, exclude jars, avoid jar conflict
[-c key1=value1,key2=value2] optional, add key=value pair to configuration
本列表命令罗列不甚详细, 具体通过jstorm help进行查看
zkServer.sh start
启动NIMBUS
jstorm nimbus &
启动SUPERVISOR
jstorm supervisor &
启动UI
jstorm ui &
部署TOPOLOGY
jstorm jar /opt/hadoop/loganalyst/storm-dependend/data/teststorm-1.0.jar teststorm.TopologyMain /opt/hadoop/loganalyst/storm-dependend/data/words.txt
删除TOPOLOGY
jstorm kill {toponame}
激活TOPOLOGY
jstorm active {toponame}
不激活TOPOLOGY
jstorm deactive {toponame}
列出所有TOPOLOGY
jstorm list
--------------------------------------------------------------------------------------------------
activate
classpath
deactivate
drpc
help
jar
kill
list
localconfvalue
metricsMonitor
nimbus
rebalance
remoteconfvalue
restart
supervisor
update_topology
zktool
[--config client_storm.yaml] optional, setting client's storm.yaml
[--exclude-jars exclude1.jar,exclude2.jar] optional, exclude jars, avoid jar conflict
[-c key1=value1,key2=value2] optional, add key=value pair to configuration
本列表命令罗列不甚详细, 具体通过jstorm help进行查看