用户组:游客
使用道具 举报
具体有多少个worker,多少个executor,每个executor负责多少个task,是由配置和指定的parallelism-hint共同决定的 1、TOPOLOGY-WORKERS参数指定了某个topology运行时需启动的worker数目. 2、parallelism-hint指定某个component(组件,如spout)的初始executor的数目. 3、TOPOLOGY-TASKS是component的tasks数,计算稍微复杂点: (1). 如果未指定TOPOLOGY-TASKS,此值等于初始executors数. (2). 如果已指定,和TOPOLOGY-MAX-TASK-PARALLELISM值进行比较,取小的那个作为实际的TOPOLOGY-TASKS. 任务分配是通过mk-assignments函数来完成.
本版积分规则 发表回复 回帖后跳转到最后一页
积极上进,爱好学习
经常参与各类话题的讨论,发帖内容较有主见
高级会员
64
主题
207
帖子
7
粉丝
查看 »