1

我们正在执行一个 Storm 拓扑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
4

1 回答 1

1

LocalCluster没有 UI 支持...因此您看到的 UI 属于不同的 Storm 集群。

更准确地说:LocalCluster不是真正的集群;它是一个执行整个拓扑的本地 JVM 进程(模仿真实的 Storm 集群)。因此,bin/storm jar ...它不会将拓扑发送到任何集群,而是运行本地 JVM(我假设是bin/storm阻塞的)。如果你想提交到一个真实的集群(并获得一个 UI,你需要使用StormSubmitter)。

于 2016-05-07T14:57:05.567 回答