2015-02-23 148 views
0

我已經在Amazon EC2實例上創建了一個風暴集羣。我在本地環境(僞分佈式環境)中測試了我的代碼,並且它工作正常。但是,當我在分佈式環境中運行代碼時,代碼似乎不起作用。 在設置集羣的同時,有沒有什麼技術我在這裏失蹤。Apache Storm Supervisor未運行螺栓

我可以聲明主管節點沒有運行螺栓,因爲我檢查了所有主管節點的CPU使用率的,並且它們都沒有超過1%,但主(nimbus)運行在每次100%,直到代碼執行完成。

我還檢查了在supervisor節點中運行的Java進程,並且「jps」未顯示我的拓撲。

注意:集羣在通過nimbus運行的用戶界面中顯示2個主管。這表明該集羣是在分佈式環境中安裝的。

+0

有什麼日誌說...可能是有用的,如果在這裏提供他們 – user2720864 2015-02-23 11:11:01

+0

我解決了我的問題,並在這裏添加我的解決方案。 – 2015-02-25 05:05:29

+1

你應該添加你的解決方案作爲答案,並接受你自己的答案;) – 2015-10-19 15:21:52

回答

1

解決我的問題:

以前我是運行使用的LocalCluster代替StormSubmitter

使用此:代替

StormSubmitter.submitTopologyWithProgressBar(args[0], conf, builder.createTopology()); 

LocalCluster cluster = new LocalCluster(); 
cluster.submitTopology("test", conf, builder.createTopology()); 
Utils.sleep(10000); 
cluster.killTopology("test"); 
cluster.shutdown();