2015-07-13 83 views
1

this文档的链接,我可以了解到再平衡的拓扑很容易与下面的命令如何重新平衡风暴三叉戟拓扑

storm rebalance mytopology -n 5 -e blue-spout=3 -e yellow-bolt=10 

但我怎么再平衡三叉戟拓扑的三叉戟拓扑我们不能用名字来标记过滤器/函数(螺栓),那么我怎样才能增加/减少并行计数?或者有没有办法使用乘法器为特定拓扑中的所有组件增加/减少并行计数?

回答

1

让我回答我自己的问题;

三叉戟喷嘴和螺栓自动命名,名称为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")