storm ui未显示拓扑

bt1cpqcv  于 2021-06-21  发布在  Storm
关注(0)|答案(1)|浏览(360)

我们正在执行一个风暴拓扑 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
mwngjboj

mwngjboj1#

localcluster不支持拓扑ui。
如果您真的想看到一台机器的拓扑结构,可以构建单节点集群,您应该在同一台机器上运行一个zookeeper、一个storm nimbus和一个storm ui线程。要将拓扑提交到集群,您应该使用 StormSubmitter 更改密码 LocalCluster cluster = new LocalCluster(); 到下面。

if (args != null && args.length > 0) {
  conf.setNumWorkers(3);

  StormSubmitter.submitTopology(args[0], conf, builder.createTopology());
}
else {

  LocalCluster cluster = new LocalCluster();
  cluster.submitTopology("test", conf, builder.createTopology());
  Utils.sleep(10000);
  cluster.killTopology("test");
  cluster.shutdown();
}

代码表明,当您添加参数时,它将拓扑发送到集群,否则,它将在本地运行拓扑。
并确保您已导入stormsubmitter import backtype.storm.StormSubmitter;

相关问题