Как запустить Apache Storm UI из кода Java? - PullRequest
Новая
       26

Как запустить Apache Storm UI из кода Java?

1 голос
/ 26 мая 2019

Я разрабатываю проект потоковой обработки с помощью Storm. Я создал топологию и запустил ее, выполнив класс Main моего проекта.

В руководствах по Storm я видел пользовательский интерфейс, доступ к которому осуществляется через порт 8080, и он отображает подробную информацию для носиков и болтов. Но я не смог найти способ запустить интерфейс. Как я могу это сделать?

pom.xml file: 

<dependency>
    <groupId>org.apache.storm</groupId>
    <artifactId>storm-core</artifactId>
    <version>1.2.2</version>
    <scope>compile</scope>
</dependency>

Основной класс: 

TopologyBuilder builder = new TopologyBuilder();
builder.setSpout("TwitchSpout", new TwitchSpout());
builder.setBolt("MessageBolt", new MessageBolt()).shuffleGrouping("TwitchSpout");

Config conf = new Config();
conf.setDebug(false);

new LocalCluster().submitTopology("MyFirstTopo", conf, builder.createTopology());

Пользовательский интерфейс, который я хочу запустить: UI

1 Ответ

1 голос
/ 27 мая 2019

Вы используете топологию как локальный кластер, который предназначен только для тестирования.Вместо этого вы должны запустить его на реальном кластере (см. https://storm.apache.org/releases/2.0.0-SNAPSHOT/Setting-up-a-Storm-cluster.html).

. После настройки вы можете запустить Storm UI с помощью команды storm ui, используя скрипт storm.sh в storm/bin.В настоящее время нет способа запустить Storm UI в LocalCluster.

...