Storm UI zeigt keine Topologie an

Question

Wir führen eine Storm-Topologie in LocalCluster aus. Die Storm-Topologie ist gut ausgeführt und kann Storm UI (8090) verbinden. Die Storm UI zeigt jedoch nicht die Informationen zur laufenden Topologie an.

LocalCluster cluster = new LocalCluster(); 

und Absenden wie:

bin/storm jar bin/StormTest-0.0.1-SNAPSHOT.jar com.abzooba.storm.twitter.TwitterTopologyCreator Twitter 

Answer 1

Die Localcluster unterstützt keine Topologie UI.
Wenn Sie die Topologie wirklich mit einer einzigen Maschine sehen möchten, können Sie den Cluster mit einem Knoten erstellen, auf dem Sie einen Tierpfleger, einen Sturmnimbus und einen Sturm-ui-Thread auf demselben Rechner ausführen. Um Ihre Topologie an den Cluster zu senden, sollten Sie StormSubmitter verwenden und Ihren Code LocalCluster cluster = new LocalCluster(); wie folgt ändern.

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(); 
} 

Der Code gibt an, wann Sie args hinzufügen, wird die Topologie in den Cluster senden, andernfalls wird es lokal ausgeführt.

Und stellen Sie sicher, dass Sie importieren StormSubmitter mit import backtype.storm.StormSubmitter;