Storm UI, не отображающий топологию

Question

Мы выполняем топологию 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 

Answer 1

Localcluster не поддерживает топологии 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(); 
} 

Код указывает при добавлении арг, он будет посылать топологию кластера, в противном случае, она будет работать локально.

И убедитесь, что у вас есть импорт StormSubmitter с import backtype.storm.StormSubmitter;