Топология Storm UI не работает
Мы выполняем топологию 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
1 ответ
LocalCluster
нет поддержки пользовательского интерфейса... Таким образом, пользовательский интерфейс принадлежит другому кластеру Storm.
Чтобы быть более точным: LocalCluster
на самом деле не кластер; это локальный процесс JVM, который выполняет всю топологию (имитируя настоящий кластер Storm). Таким образом, bin/storm jar ...
не отправляет топологию ни в один кластер, но запускает локальную JVM (я предполагаю, что bin/storm
блоки). Если вы хотите отправить в реальный кластер (и получить пользовательский интерфейс, вам нужно использовать StormSubmitter
).