我正在运行wordcount风暴拓扑(https://github.com/nathanmarz/storm-starter/).
我将通过storm Thread启动此拓扑,但它没有运行任何工作节点。在storm ui中,我看不到分配的任何主管节点。在我的代码中,我配置为启动三个工作节点。我们需要做些别的事情来让主管们开始工作吗?
我还查看了nimbus.log、stderr、stdout&ui.log,没有错误的迹象。
storm jar target/storm-starter-0.9.3-rc2-SNAPSHOT-jar-with-dependencies.jar storm.starter.WordCountTopology TEST-WC-TOPO 1045 [main] INFO backtype.storm.StormSubmitter - Successfully uploaded topology jar to assigned location: storm-local/nimbus/inbox/stormjar-4a08ebf7-022c-4b22-86be-1efc6e8f6be0.jar 1046 [main] INFO backtype.storm.StormSubmitter - Submitting topology WCT in distributed mode with conf {"topology.workers":3,"topology.debug":true} 1438 [main] INFO backtype.storm.StormSubmitter - Finished submitting topology: WCT
暂无答案!
目前还没有任何答案,快来回答吧!