小智 4
当您通过“storm jar ...”提交拓扑时,Storm 会将任务分配给工作人员
典型的 Storm 集群将有许多 Supervisor(也称为 Storm 节点)。每个Supervisor节点(服务器)都会运行许多Worker进程。每个 Supervisor 的工作人员数量取决于您使用supervisor.slots.ports 分配的端口数量。
当通过“storm jar”提交拓扑时,Storm 平台会确定哪些工作线程将托管您的每个 spout 和 Bolt(也称为任务)。托管拓扑的工作线程和执行器的数量取决于您在开发期间、提交拓扑时设置的“并行度”,或使用“风暴重新平衡”在实时运行的拓扑中更改时设置的“并行度”。
Michael Noll 在他的博客文章中对并行性、工作人员和任务进行了详细分析:http://www.michael-noll.com/blog/2012/10/16/understand-the-parallelism-of-a-storm-拓扑/#运行拓扑示例
| 归档时间: |
|
| 查看次数: |
1215 次 |
| 最近记录: |