假设我有一个由三台服务器组成的 Storm 集群，命名为server1, server2, server3。Server1作为主节点运行，server2 and 3作为辅助节点运行。
当我向Server1提交一个topology时，它总是将拓扑分布为在Server2上运行。
但是Server2有问题（新提交的topologies可以运行，但不能真正工作，我不知道为什么），所以我想改变topologies运行的服务器。
我的问题是
如何将拓扑提交到指定的工作服务器？
1条答案
按热度按时间vjhs03f71#
我猜你把worker和supervisor搞混了。supervisor在集群中的每个节点上运行，并在启动Storm集群时启动。如果提交了拓扑，worker将由supervisor启动。你可以在storm.yaml中为每个supervisor配置workers的最大数量。Nimbus仅与supervisor通信（通过Zookeeper）：请参阅https://storm.apache.org/documentation/Tutorial.html
此外，您可以在Storm中实现自定义调度程序，从而影响拓扑提交到哪些节点（即主管）。
希望这对你有帮助。