任务槽 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架构原理