我有一个nimbus服务器和3个其他管理服务器。我有11个storm拓扑在运行。但它们都是在光环中运行的。如何配置其他监控器,以便拓扑分布在各个监控器之间。我必须更改哪些配置文件?
dpiehjr41#
好像发生了什么有趣的事。两位主持人 corona-stage-storm-supervisor-01 以及 corona-stage-storm-supervisor-02 每人有两名主管。但是,主机只能运行一个监控器。我假设这会“混淆”光轮,并使用剩余的主机( corona-storm-nimbus-01 )只有一个主管在运行。有关更多详细信息,请参阅storm文档(并与进行设置的管理员联系):https://storm.apache.org/releases/1.0.0/setting-up-a-storm-cluster.html关于worker的数量:这个参数定义了一个拓扑使用了多少worker jvm(supervisor jvm启动执行实际工作的worker jvm——supervisor基本上是协调的“本地主机”)。您可以在作业配置中通过 conf.setNumWorkers(int) . 如果希望拓扑分布在多个主机上,则需要增加参数。不过,对于您的案例中的多个拓扑,值为1也可以——不同的拓扑应该在不同的主机上运行,与此参数无关。有关更多详细信息,请参阅storm文档:https://storm.apache.org/releases/1.0.0/understanding-the-parallelism-of-a-storm-topology.html
corona-stage-storm-supervisor-01
corona-stage-storm-supervisor-02
corona-storm-nimbus-01
conf.setNumWorkers(int)
1条答案
按热度按时间dpiehjr41#
好像发生了什么有趣的事。两位主持人
corona-stage-storm-supervisor-01
以及corona-stage-storm-supervisor-02
每人有两名主管。但是,主机只能运行一个监控器。我假设这会“混淆”光轮,并使用剩余的主机(corona-storm-nimbus-01
)只有一个主管在运行。有关更多详细信息,请参阅storm文档(并与进行设置的管理员联系):
https://storm.apache.org/releases/1.0.0/setting-up-a-storm-cluster.html
关于worker的数量:这个参数定义了一个拓扑使用了多少worker jvm(supervisor jvm启动执行实际工作的worker jvm——supervisor基本上是协调的“本地主机”)。您可以在作业配置中通过
conf.setNumWorkers(int)
. 如果希望拓扑分布在多个主机上,则需要增加参数。不过,对于您的案例中的多个拓扑,值为1也可以——不同的拓扑应该在不同的主机上运行,与此参数无关。有关更多详细信息,请参阅storm文档:
https://storm.apache.org/releases/1.0.0/understanding-the-parallelism-of-a-storm-topology.html