storm如何将任务分配给员工？负载平衡是如何工作的？
xzlaal3s1#
当您通过“storm jar…”提交拓扑时，storm会将任务分配给Worker一个典型的风暴群将有许多管理者（又称风暴节点）。每个主管节点（服务器）将有许多工作进程在运行。每个监控器的工作进程数由您使用supervisor.slots.ports分配的端口数决定。当拓扑通过“storm jar”提交时，storm平台决定哪些工人将托管您的每个喷口和螺栓（又称任务）。将承载拓扑的worker和executors的数量取决于您在开发过程中设置的“并行度”（提交拓扑时），或使用“storm rebalance”在实时运行的拓扑中更改拓扑时设置的“并行度”。michael noll在他的博客文章中对并行性、工作人员和任务进行了详细的分析：http://www.michael-noll.com/blog/2012/10/16/understanding-the-parallelism-of-a-storm-topology/#example-运行拓扑
1条答案
按热度按时间xzlaal3s1#
当您通过“storm jar…”提交拓扑时，storm会将任务分配给Worker
一个典型的风暴群将有许多管理者（又称风暴节点）。每个主管节点（服务器）将有许多工作进程在运行。每个监控器的工作进程数由您使用supervisor.slots.ports分配的端口数决定。
当拓扑通过“storm jar”提交时，storm平台决定哪些工人将托管您的每个喷口和螺栓（又称任务）。将承载拓扑的worker和executors的数量取决于您在开发过程中设置的“并行度”（提交拓扑时），或使用“storm rebalance”在实时运行的拓扑中更改拓扑时设置的“并行度”。
michael noll在他的博客文章中对并行性、工作人员和任务进行了详细的分析：http://www.michael-noll.com/blog/2012/10/16/understanding-the-parallelism-of-a-storm-topology/#example-运行拓扑