分享

Storm单机运行是不是不需要启动zookeeper、Nimbus、Supervisor ?

1.我用Storm单机模式运行,没有启动zookeeper、Nimbus、Supervisor,直接在终端输入命令:
./storm jar /home/chimes/workspace/Test1/target/Test1-1.0-SNAPSHOT.jar strom.chimes.WordCountTopology Topology  wordcount
作业就启动并运行成功。

是不是单机环境不需要启动zookeeper、Nimbus、Supervisor?

2.另外,当我依次启动zookeeper、Nimbus、Supervisor、storm ui:
./zkServer start
bin/storm nimbus& bin/storm supervisor& bin/storm ui&
然后运行1中的topology,在浏览器访问Storm ui,ui并没有显示有topology在运行。
1.png

storm的配置如下:
2.png

已有(4)人评论

跳转到指定楼层
NEOGX 发表于 2015-9-26 22:41:56
单击也是需要启动的,建议全部启动,然后在运行拓扑,然后对比下
回复

使用道具 举报

chimes298 发表于 2015-9-26 23:32:14
NEOGX 发表于 2015-9-26 22:41
单击也是需要启动的,建议全部启动,然后在运行拓扑,然后对比下

一个是我全启动之后,storm ui不显示我的topology,如图中显示,是哪里配置不对吗?
另一个全都不启动,用storm jar运行,还能得到正确结果。。。不知道为什么
回复

使用道具 举报

chimes298 发表于 2015-9-27 01:50:54
研究一天终于搞明白了。
如果用下面方式提交:[mw_shl_code=actionscript3,true]LocalCluster cluster = new LocalCluster();
cluster.submitTopology(TOPOLOGY_NAME, config, builder.createTopology());[/mw_shl_code]
就不需要运行zookeeper,nimbus,supervisor,在storm ui也不会显示topology,因为是本地模拟。

如果用下面方式:[mw_shl_code=actionscript3,true]StormSubmitter.submitTopology(TOPOLOGY_NAME, config, builder.createTopology());[/mw_shl_code]
则需要启动zookeeper,nimbus,supervisor,会在storm ui显示
回复

使用道具 举报

levycui 发表于 2015-9-29 15:35:53
学习,感谢分享
回复

使用道具 举报

您需要登录后才可以回帖 登录 | 立即注册

本版积分规则

关闭

推荐上一条 /2 下一条