Flink基础教程

Flink

的用途

｜

33

Flink

所用的技术叫作

检查点

（

checkpoint

）， 第

5

章会详细介绍它的原理。

在每个检查点，系统都会记录中间计算状态，从而在故障发生时准确地重

置。这一方法使系统以低开销的方式拥有了容错能力——当一切正常时，

检查点机制对系统的影响非常小。

值得注意的是，检查点也是

Flink

能够按需重新处理数据的关键所在。毕

竟，并不是只有在发生故障之后才会重新处理数据。比如，在运行新模型

或者修复

bug

时，就可能需要重播并重新处理事件流数据。

Flink

成全了这

些操作。

Flink

的检查点特性在流处理器中是独一无二的，它使得

Flink

可以准确地维持状态，并且高效地重新处理数据。

3.1.4

　及时给出所需结果

Flink

能够满足低延迟应用程序的需要，将这算作一种正确性可能出人意

料。我们换个角度看看：有些计算结果或许很准确，例如求和或者求平均

值的结果，但是如果没有及时地取得结果，那么很难说它们是正确的。举

一个例子，假设你在开车上班的途中想通过智能手机上的实时路况查询及

导航应用程序选择一条畅通的路，如果应用程序花了

2

小时才把查询结果

发给你，那么结果再准确也是无用的。哪怕只有

5

秒钟的延迟也足以造成

麻烦，因为你可能已经拐错了弯。

可见，在某些情况下，极低的延迟非常重要，它决定了系统能够及时地给

出所需结果，而不仅仅是完成计算。

Flink

的实时且容错的流处理能力可以

满足这类需求。

3.1.5

　使开发和运维更轻松

Flink

与用户交互的接口也有助于保障正确性。完备的语义简化了开发工

作，进而降低了出错率 ...