学习了!!! |
Flink 的整体结构 运行模式 | runtime | Api Flink的WindowFuncation 滑动 | 滚动 | 会话 Flink的容错 -- CheckPoint(Job Manager)中 使用了Chandy Lamport算法, 容错机制为流创建了有关快照的确切详细信息,这个过程是轻量级的异步的快照,如果发生问题后,Flink会从最新的一些检查点中的信息,重新开始执行 Barriers CheckPoint核心要素之一,有一个唯一ID,每个状态都会给JobManager发送快照状态信息 | 后面的还不是很清楚 |
感谢分享 |
Flink实时性、容错机制、窗口,good |