Flink 1.5版本的“Task本地恢复”实现摘要

overview 解读Flink 1.5版本的“task本地恢复”feature的实现。java 随着时间的推移,Flink有些模块的代码复杂度已经很高了(比较典型的就是状态&容错这块)。由于考虑到兼容历史实现的问题,类在快速增加。web 实现 关于本地恢复的配置,封装在名为LocalRecoveryConfig的类中,该类可提供本地恢复模式的查询(也即LocalRecoveryMode枚举)以及
相关文章
相关标签/搜索