我们正在执行一个风暴拓扑 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条答案
按热度按时间ztmd8pv51#
LocalCluster
没有ui支持。。。因此,您看到的ui属于另一个storm集群。更准确地说:
LocalCluster
不是真正的集群;它是一个本地jvm进程,执行整个拓扑结构(模拟真实的风暴集群)。因此,bin/storm jar ...
不将拓扑发送到任何集群,而是运行本地jvm(我假设bin/storm
块)。如果您想提交到一个真正的集群(并获得一个ui),您需要使用StormSubmitter
).