-
Flink 基础开发常用方式 0:00~1:18
-
Flink 原理 TaskManager & slot & 并行度 & Task 关系 1:18 ~ 2:08
-
Flink 数据传输策略 2:09~2:50
数据传输策略
-
forward strategy
-
一个 task 的输出只发送给一个 task 作为输入
-
如果两个 task 都在一个 JVM 中的话,那么就可以避免网络开销
-
key based strategy
-
数据需要按照某个属性(我们称为 key)进行分组(或者说分区)
-
相同 key 的数据需要传输给同一个 task,在一个 task 中进行处理
-
Flink 分布式四层模型 2:51 ~
网友评论