apache-storm - 如何重新平衡 Storm Trident 拓扑

Question

从 这个文档链接中，我可以了解到使用以下命令很容易重新平衡拓扑

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

但是如何重新平衡三叉戟拓扑，因为在三叉戟拓扑中我们不能用名称标记过滤器/功能（螺栓），那么如何增加/减少并行计数？或者有没有办法使用特定拓扑中所有组件的乘数来增加/减少并行计数？

Answer 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

注意：您还可以在创建 Trident 拓扑时命名螺栓

例如;

 topology.newStream("spout", spout)
         .each(new Fields("sentence"), new Split(), new Fields("word"))
         .shuffle()
         .name("BOLT-NAME")