Flink基础教程

32

｜

第

3

章

处理时间 事件时间

图 3-3：从处理时间切换到事件时间，让许多计算工作完成得更好。用处理时间

来计算会导致错误，用事件时间则能得到正确的结果（图片来源：Jamie Grier 于

2016 年 5 月在 OSCON 大会上所做的演示）

与其他流处理系统相比，

Flink

的一个优势就是能区分不同类型的时间。

3.1.3

　发生故障后仍保持准确

若想使计算保持准确，就必须跟踪计算状态。如果计算框架本身不能做到

这一点，就必须由应用程序的开发人员来完成这个任务。连续的流处理很

难跟踪计算状态，因为计算过程没有终点。实际上，对状态的更新是持续

进行的。

Flink

解决了可能影响正确性的几个问题，包括如何在故障发生之后仍能进

行有状态的计算。