storm如何部署拓扑
storm集群搭建
比较简单,参考官方文档即可http://storm.apache.org/releases/1.0.2/Setting-up-a-Storm-cluster.html
启动Nimbus
./bin/storm nimbus &
- 启动Storm UI,方便对集群状态的监控。
./bin/storm ui &
- 启动supervisor
./bin/storm supervisor &
更新git代码
git pull --rebase
maven命令打包,xxx-0.0.1-SNAPSHOT.jar
mvn package
提交拓扑
- 上传jar包并部署到Nimbus主机,并执行如下命令,
./bin/storm jar myTopology/xxx-0.0.1-SNAPSHOT.jar com.oplan.storm.topology.InsightTopology 201609071857
查看监控图,
- 在Topology Summary栏目下能看到刚刚部署的拓扑的状态,Supervisor Summary则是supervisor的状态。
- 可以看到拓扑的所有spout和所有bolt状态。
删除拓扑
- storm kill {toponame}
- 或直接在监控页面上kill按钮
最终展示实时运算结果
========广告时间========
鄙人的新书《Tomcat内核设计剖析》已经在京东销售了,有需要的朋友可以到 https://item.jd.com/12185360.html 进行预定。感谢各位朋友。
=========================
欢迎关注:

低调大师中文资讯倾力打造互联网数据资讯、行业资源、电子商务、移动互联网、网络营销平台。
持续更新报道IT业界、互联网、市场资讯、驱动更新,是最及时权威的产业资讯及硬件资讯报道平台。
转载内容版权归作者及来源网站所有,本站原创内容转载请注明来源。
- 上一篇
hadoop 1.1.2和 hive 0.10 和hbase 0.94.9整合
今天弄了一下hive0.10和hbase0.94.9整合,需要设置的并不多,但是也遇到了一些问题。 1.复制jar包 拷贝hbase-0.94.9.jar,zookeeper-3.4.5.jar,protobuf-java-2.4.0a.jar到hive/lib下,删掉lib下面旧版的jar包。 拷贝hbase-0.94.9.jar到所有hadoop节点的lib文件夹下面,拷贝hbase/confi的hbase-site.xml文件拷贝到所有的hadoop节点conf文件夹下。 2.修改hive-site.xml配置文件,添加以下内容 <property> <name>hive.querylog.location</name> <value>/usr/hive/logs</value> </property> <property> <name>hive.aux.jars.path</name> <value>file:///usr/hive/lib/hive-hbas...
- 下一篇
Filebeat 日志收集器 logstash-forwarder 的替代品
Filebeat是一个开源的文件收集器,主要用于获取日志文件,并把它们发送到logstash或elasticsearch。与libbeat lumberjack一起替代logstash-forwarder。 在logstash-forwarder项目上,看到下面一些信息“The filebeat project replaces logstash-forwarder. Please use that instead.No further development will occur on this project. Major bug fixes or security fixes may be worked on through 2016, at which point this repository and its project will be abandoned.The replacement is filebeat which receives new features and fixes frequently.” 说明了啥?简单而言logstash-forwarder寿终正...
相关文章
文章评论
共有0条评论来说两句吧...