Apache風暴配置

Question

我正面臨着爲拓撲設置隔離調度程序的問題。 基本上我試圖設置一臺機器的數量，如下所示。

Map<String, Number> topologyToMachines = new HashMap<String, Number>(); 
topologyToMachines.put(TOPOLOGY_NAME, 1); 
config.put(Config.STORM_SCHEDULER, "backtype.storm.scheduler.IsolationScheduler"); 
config.put(Config.ISOLATION_SCHEDULER_MACHINES, topologyToMachines); 

如果我像上面那樣設置，nimbus沒有爲這個拓撲指定一個節點。我爲這種拓撲設置了兩名工作人員。這兩個工人被分配到兩個節點，而不是隻有一個節點。

但是，如果我在nimbus節點中更改配置storm.yaml並提交相同的拓撲結構，則只會爲此拓撲分配一個節點。

這是Storm中的一個bug嗎？我正在使用0.9.1版本。

Answer 1

這種行爲似乎很正常。當添加隔離設置時抽取Storm 0.8.2 release notes。

提交給未列出的集羣的任何拓撲都不會被隔離。請注意，Storm的用戶無法影響其隔離設置 - 只有羣集的管理員才允許這種設置（這是非常有意的）。