Flink应用(3)
1 回顾
上一篇文章对Flink中的核心概念之Time和Window设计之因做了深入的探讨。先来回顾一下:
EventTime是具有反演特性的现代流式计算建模的核心,在如何避免传输延时带来的错窗问题上,Flink使用watermark和Lateness机制进行处理,使得整个基础更加稳固。同时提供丰富的Window生成和计算机制,使得编写流式计算应用变得简单。
成熟的计算系统还必须具备健壮性,才能承担起更重要的业务应用。Flink中的窗口计算大多需要依赖历史计算结果,这种计算称之为有状态的
。在分布式系统中,状态是引起复杂性的根源之一。Flink如何保证有状态的计算
足够健壮,将在本篇进行说明。