我正在学习storm。我对apache storm上一次可以运行的拓扑数量有疑问。我在storm群集上提交了两个拓扑，但一次只运行一个拓扑。我需要终止或停用现有拓扑才能运行任何新拓扑。
我正在使用storm 0.9.4
Zookeeper3.4.6
Kafka2.10-0.8.2.1
我正在运行storm nimbus、supervisor和ui的一个示例。
我需要运行每个的多个示例吗？
要同时运行多个拓扑，我需要做什么？
我附上我的风暴用户界面截图。
我正在学习storm。我对apache storm上一次可以运行的拓扑数量有疑问。我在storm群集上提交了两个拓扑，但一次只运行一个拓扑。我需要终止或停用现有拓扑才能运行任何新拓扑。
我正在使用storm 0.9.4
Zookeeper3.4.6
Kafka2.10-0.8.2.1
我正在运行storm nimbus、supervisor和ui的一个示例。
我需要运行每个的多个示例吗？
要同时运行多个拓扑，我需要做什么？
我附上我的风暴用户界面截图。
1条答案
按热度按时间xmakbtuz1#
我只使用了2个supervisor.slots.ports（在storm.yaml中），拓扑配置中的setnumworkers（）也被指定为2。因此，首先运行的拓扑占用了这两个插槽。现在，我已经设置了5个supervisor.slots.ports，一切正常。我可以一次运行多个拓扑。