Apache Flink

Ch10-Flink 之 BackPressure

January 3, 2021
Apache Flink
flink

Flink 1.5 之前使用的是 TCP-Based 反压机制,自 Flink 1.5(包含) 使用的是 Credit-Based 反压机制。

tcp flow

简单来说,如果反压机制实现在 Socket 层,那便是 TCP-Based 反压机制;如果实现在 Netty 层,那便是 Credit-Based 反压机制。

...

Ch09-Flink 之 Savepoint

December 31, 2020
Apache Flink
flink

Savepoint 跟 Checkpoint 的差别在于 Checkpoint 是 Flink 对于一个有状态应用在运行中利用分布式快照持续周期性的产生 Checkpoint,而 Savepoint 则是手动产生的 Checkpoint,Savepoint 记录着流式应用中所有运算元的状态。

...