安装
- 下载地址:https://www.apache.org/dyn/closer.lua/storm/apache-storm-1.2.1/apache-storm-1.2.1.tar.gz
- 配置环境变量(我这里是用户级别)
- 进入conf,修改storm.yaml
vim ~/.bash_profile
export STORM_HOME=/root/apache-storm-1.2.1
export PATH=$PATH:$STORM_HOME/bin
source ~/.bash_profile
echo $STORM_HOME
查询
jps
jps -m
jps -l
以后台方式启动(bin目录)
nohup sh storm dev-zookeeper &
nohup sh storm nimbus &
nohup sh storm supervisor &
nohup sh storm ui &
运行jar包
storm jar topology-jar-path class ...
storm jar study-storm-1.0-SNAPSHOT.jar com.st.ClusterSumStormTopology
关闭任务
storm kill topology-name [-w wait-time-secs]
storm kill ClusterSumStormTopology
列出任务及状态
storm list
停止集群
jps
kill -9 pid, pid ...
参考博客
官方文档,包括配置,各种命令等
[1]http://storm.apache.org/releases/1.1.2/index.html
[2]https://blog.csdn.net/qq_37095882/article/category/7055953