Flink实时性、容错机制、窗口等介绍

查看数: 26214 | 评论数: 4 | 收藏 3
关灯 | 提示:支持键盘翻页<-左 右->
    组图打开中,请稍候......
发布时间: 2018-10-8 16:16

正文摘要:

本帖最后由 pig2 于 2018-10-8 16:17 编辑 问题导读 1.为什么flink实时性好? 2.flink通过什么机制保证数据既不重复,也不丢失? 3.flink采用什么机制通信? 4.flink有哪些窗口,他们的作用是什么? 最 ...

回复

qx_code 发表于 2020-8-20 10:26:04
学习了!!!
若无梦何远方 发表于 2019-8-21 16:17:23
Flink 的整体结构 运行模式 | runtime | Api
Flink的WindowFuncation 滑动 | 滚动 | 会话
Flink的容错 -- CheckPoint(Job Manager)中 使用了Chandy Lamport算法, 容错机制为流创建了有关快照的确切详细信息,这个过程是轻量级的异步的快照,如果发生问题后,Flink会从最新的一些检查点中的信息,重新开始执行
Barriers CheckPoint核心要素之一,有一个唯一ID,每个状态都会给JobManager发送快照状态信息 | 后面的还不是很清楚
美丽天空 发表于 2018-10-9 09:07:03
感谢分享
jiangzi 发表于 2018-10-8 20:22:15
Flink实时性、容错机制、窗口,good
关闭

推荐上一条 /2 下一条