在Storm集群下运行项目

举报
Smy1121 发表于 2019/06/21 19:37:35 2019/06/21
【摘要】 在Storm集群下运行项目

导入apache-storm项目

1. 将 apache-storm-0.9.6.tar.gz解压到本地,得到apache-storm-0.9.6文件夹

image.png

2. 将apache-storm-0.9.6导入到IntellJ IDEA中

image.png

image.png

image.png

image.png

image.png

image.png

image.png

image.png


3. 将项目编译打包

image.png

image.png

image.png


去项目的target目录下查看,可以看到已经生成的jar包

image.png


4. 在nimbus的主目录下创建project目录

image.png


5. 使用WinSCP将带有依赖的jar包上传到nimbus的project目录下

image.png

image.png

image.png


6. 启动storm-starter项目

image.png


7. 查看storm-starter项目


a. 命令行

image.png


b. Storm UI

刷新storm UI

image.png


点击topology名称test1,查看topology详情

image.png

其中 Deactive是暂停任务,Reblance是将topology重新在storm集群分配, kill是杀掉任务


image.png

Show Visualization是对任务的spout、bolt进行图形化展示


8. 停止storm-starter项目

a) 命令行

image.png


b) Storm UI

把storm任务重新启动,通过Storm UI杀掉

点击kill

image.png


返回storm UI首页,刷新页面查看

image.png


再过一段时间,该任务彻底消失。

【版权声明】本文为华为云社区用户原创内容,未经允许不得转载,如需转载请自行联系原作者进行授权。如果您发现本社区中有涉嫌抄袭的内容,欢迎发送邮件进行举报,并提供相关证据,一经查实,本社区将立刻删除涉嫌侵权内容,举报邮箱: cloudbbs@huaweicloud.com
  • 点赞
  • 收藏
  • 关注作者

评论(0

0/1000
抱歉,系统识别当前为高风险访问,暂不支持该操作

全部回复

上滑加载中

设置昵称

在此一键设置昵称,即可参与社区互动!

*长度不超过10个汉字或20个英文字符,设置后3个月内不可修改。

*长度不超过10个汉字或20个英文字符,设置后3个月内不可修改。