flink
Ch13-Flink 之 细粒度资源管理
January 24, 2021
Flink 之 细粒度资源管理
...Ch12-Flink 之 Window
January 15, 2021
Flink 之 Window
...Ch11-Flink 之 Watermark
January 9, 2021
Flink 之 watermark
...Ch10-Flink 之 BackPressure
January 3, 2021
Flink 1.5 之前使用的是 TCP-Based 反压机制，自 Flink 1.5(包含) 使用的是 Credit-Based 反压机制。
简单来说，如果反压机制实现在 Socket 层，那便是 TCP-Based 反压机制；如果实现在 Netty 层，那便是 Credit-Based 反压机制。
...Ch09-Flink 之 Savepoint
December 31, 2020
Savepoint 跟 Checkpoint 的差别在于 Checkpoint 是 Flink 对于一个有状态应用在运行中利用分布式快照持续周期性的产生 Checkpoint，而 Savepoint 则是手动产生的 Checkpoint，Savepoint 记录着流式应用中所有运算元的状态。
...Ch08-Flink 之 Checkpoint
December 25, 2020
Checkpoint 属于一种机制，State + ABS(Asynchronouse Barrier Snapshot)。
Ch07-Flink 之 State
December 20, 2020
State 指一个具体的 task/operator 的状态，State Backends 指具体状态的存储介质
...Ch06-Flink 之 容错机制
December 13, 2020
Flink 容错机制
...Ch05-Flink 之 内存管理
December 5, 2020
Flink 内存管理
...