【问题标题】:Storm UI not showing topologyStorm UI 未显示拓扑
【发布时间】:2016-05-09 00:17:58
【问题描述】:

我们正在LocalCluster 中执行 Storm 拓扑。 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

【问题讨论】:

标签: apache-storm


【解决方案1】:

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();
}

代码中表示当你添加args时,它将拓扑发送到集群,否则将在本地运行。

并确保您已使用 import backtype.storm.StormSubmitter; 导入 StormSubmitter

【讨论】:

  • 如何像本地集群关闭方法一样关闭提交?
猜你喜欢
  • 1970-01-01
  • 1970-01-01
  • 2016-08-30
  • 2019-05-24
  • 1970-01-01
  • 1970-01-01
  • 1970-01-01
  • 1970-01-01
  • 2014-04-27
相关资源
最近更新 更多