Топология 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).

Другие вопросы по тегам