我们正在执行一个风暴拓扑 LocalCluster
. storm拓扑执行良好,能够连接storm ui(8090)。但是storm ui没有显示正在运行的拓扑信息。
LocalCluster cluster = new LocalCluster();
像这样提交:
bin/storm jar bin/StormTest-0.0.1-SNAPSHOT.jar com.abzooba.storm.twitter.TwitterTopologyCreator Twitter
我们正在执行一个风暴拓扑 LocalCluster
. storm拓扑执行良好,能够连接storm ui(8090)。但是storm ui没有显示正在运行的拓扑信息。
LocalCluster cluster = new LocalCluster();
像这样提交:
bin/storm jar bin/StormTest-0.0.1-SNAPSHOT.jar com.abzooba.storm.twitter.TwitterTopologyCreator Twitter
1条答案
按热度按时间mwngjboj1#
localcluster不支持拓扑ui。
如果您真的想看到一台机器的拓扑结构,可以构建单节点集群,您应该在同一台机器上运行一个zookeeper、一个storm nimbus和一个storm ui线程。要将拓扑提交到集群,您应该使用
StormSubmitter
更改密码LocalCluster cluster = new LocalCluster();
到下面。代码表明,当您添加参数时,它将拓扑发送到集群,否则,它将在本地运行拓扑。
并确保您已导入stormsubmitter
import backtype.storm.StormSubmitter;