1
從this文檔的鏈接,我可以瞭解到再平衡的拓撲很容易與下面的命令如何重新平衡風暴三叉戟拓撲
storm rebalance mytopology -n 5 -e blue-spout=3 -e yellow-bolt=10
但我怎麼再平衡三叉戟拓撲的三叉戟拓撲我們不能用名字來標記過濾器/函數(螺栓),那麼我怎樣才能增加/減少並行計數?或者有沒有辦法使用乘法器爲特定拓撲中的所有組件增加/減少並行計數?
從this文檔的鏈接,我可以瞭解到再平衡的拓撲很容易與下面的命令如何重新平衡風暴三叉戟拓撲
storm rebalance mytopology -n 5 -e blue-spout=3 -e yellow-bolt=10
但我怎麼再平衡三叉戟拓撲的三叉戟拓撲我們不能用名字來標記過濾器/函數(螺栓),那麼我怎樣才能增加/減少並行計數?或者有沒有辦法使用乘法器爲特定拓撲中的所有組件增加/減少並行計數?
讓我回答我自己的問題;
三叉戟噴嘴和螺栓自動命名,名稱爲b-0,b-1,b-2。這代表Blot-1和Bolt-2。這些名稱可以在Storm UI中找到,用於已部署的拓撲
現在使用這些螺栓名稱,我們可以重新平衡已部署的拓撲。
storm rebalance mytopology -n 5 -e b-0=3 -e b-1=10
注:同時創造一個三叉戟拓撲
例如,您也可以命名一個螺栓;
topology.newStream("spout", spout)
.each(new Fields("sentence"), new Split(), new Fields("word"))
.shuffle()
.name("BOLT-NAME")