任务槽 task slots
slot共享
并行度：算子的子任务个数
程序的并行度：最大算子并行度
假设：
设置全局并行度为6，保持sink为1
source，map(6) -》keyby。。。(6) -》sink(1)
总共有13个子任务
2 个taskmanger , 每个taskmanger 3个slot
任务槽 task slots
# Related Post
1.任务生成和分配
2.算子链
3.容错机制
4.watermark(水位线)
5.时间语义(Notions of Time)
6.处理无界和有界数据
7.flink部署
8.Flink架构原理
1.任务生成和分配
2.算子链
3.容错机制
4.watermark(水位线)
5.时间语义(Notions of Time)
6.处理无界和有界数据
7.flink部署
8.Flink架构原理
未找到相关的 Issues 进行评论
请联系 @hlw95 初始化创建