Flink源码解析之State的实现

State的实现 Flink经过异步的checkpoint机制来实现流式处理过程当中的容错，简单来说就是定时地将本地的状态序列化到一个持久存储中，当出现错误是经过恢复检查点的状态来实现容错的，对于机制的详细介绍能够参见这个连接，本章主要讲述flink源码中state的实现。html StateBackendapache flink将咱们代码中的操做转化为一个个的task放在taskmanager中

>>阅读原文<<