前言：本篇关注Flink，对Fault Tolerance的源码实现进行阐述，主要介绍Api层及Flink现有实现。 本篇文章重点关注以下问题： 具备Fault Tolerance能力的两种对象：Function和Operator分析两个接口，列举典型实现，并做简要分析 1. 具备Fault Tolerance能力的两种对象 Function Operator 1.1 Functi