假设我有一个由三台服务器组成的风暴群集,名为server1, server2, server3
。
[Server1
作为主节点运行,server2 and 3
作为工作节点运行。
当我向topology
提交Server1
时,它总是分发拓扑以在Server2
上运行。
但是Server2
出了点问题(新提交的topologies
可以运行,但不能真正工作,我不知道为什么),所以我想更改要运行topologies
的服务器。
这是我的问题:
我如何将拓扑提交到指定的工作服务器?
我想你使上司与上司混淆。主管正在集群中的每个节点上运行,并在启动Storm集群时启动。如果提交了拓扑,则工作人员由主管启动。您可以在storm.yaml中为每个主管配置最大工人数。 Nimbus仅与主管沟通(通过Zookeeper):请参阅https://storm.apache.org/documentation/Tutorial.html
此外,您可以在Storm中实现自定义调度程序,从而影响将拓扑提交到哪个节点(即,主管)。
希望这会有所帮助。