2014-10-30 35 views
0

我有1动物园管理员,1个雨云和2主管和我提交一个罐子其中两个拓扑结构可通过一个主方法经由StormSubmitter是提交如何提交从同一罐的相同的主方法两种拓扑结构在风暴簇

public static void main(String arg[]) 
{ 
..... 
Config conf=new Config(); 
StormTopology aTopology = ATopologyBuilder.buildTopology(zkHost).createTopology(); 
StormTopology bTopology = BTopologyBuilder.buildTopology(zkHost).createTopology(); 
StormSubmitter.submitTopology("A", conf, aTopology); 
StormSubmitter.submitTopology("B", conf, bTopology); 
..... 
} 

一旦我在风暴雨云,风暴监督员,暴风雨ui之后,在“风暴瓶子”中提交了这个罐子。我目前的主要方法是在节点1上正常工作,但它不在监控器上显示。

但是,当我尝试wordcount程序相同的步骤。它在节点2上执行,并在Storm UI上显示。

请帮我在暴风雨ui中显示提交的拓扑。

回答

0

通过如下改变我的代码,并复制我的罐子到inputjar location.It现在提交强攻集群和显示的UI

Config conf = new Config(); 
conf.setDebug(true); 
conf.setNumWorkers(20); 
String inputjar="C:/storm/bin/Main.jar"; 
System.setProperty("storm.jar",inputjar); 
StormTopology aTopology = ATopologyBuilder.buildTopology(zkHost).createTopology(); 
StormTopology bTopology = BTopologyBuilder.buildTopology(zkHost).createTopology(); 
StormSubmitter.submitTopology("A", conf, aTopology); 
StormSubmitter.submitTopology("B", conf, bTopology); 
相关问题