寂寞抽屉

文章
4
资源
0
加入时间
2年10月18天

Flink 内核原理与实现-入门一、核心特点二、架构

一、核心特点1.1、流批一体1、无界数据无界数据是持续产生的数据,所以必须持续的处理无界数据流。因为输入是无限的,没有终止时间。处理无界数据通常要求以特定顺序获取,以便判断事件是否完整、有无遗漏。2、有界数据 有界数据就是在一个确定的时间范围内的数据流,有开始有结束,一旦确定了就不会再改变。1.2、可靠的容错能力1、集群级容错与集群管理器集成Flink与集群管理器紧密集成,例如Yarn、K8s。当进程挂掉时,将自动启动一个新进程...