Apache Flink 进阶(一):Runtime 核心机制剖析(14)
图11.Region-based 错误恢复策略示例二 。 如果是由于上游失败导致的错误 , 那么需要同时重启上游的 Region 和下游的 Region 。 实际上 , 如果下游的输出使用了非确定的数据分割方式 , 为了保持数据一致性 , 还需要同时重启所有上游 Region 的下游 Region 。
除了 Task 本身执行的异常外 , 另一类异常是 Flink 集群的 Master 进行发生异常 。 目前 Flink 支持启动多个 Master 作为备份 , 这些 Master 可以通过 ZK 来进行选主 , 从而保证某一时刻只有一个 Master 在运行 。 当前活路的 Master 发生异常时某个备份的 Master 可以接管协调的工作 。 为了保证 Master 可以准确维护作业的状态 , Flink 目前采用了一种最简单的实现方式 , 即直接重启整个作业 。 实际上 , 由于作业本身可能仍在正常运行 , 因此这种方式存在一定的改进空间 。
5. 未来展望
Flink目前仍然在Runtime部分进行不断的迭代和更新 。 目前来看 , Flink未来可能会在以下几个方式继续进行优化和扩展:
- 第五人格|梦幻西游:担心的事发生了,大佬进阶110选错召唤兽,白花了2000块
- 盲僧|英雄联盟手游:打野玩家的进阶选择,盲僧,高机动性带来的直接收益
- 我的世界|剑网3药宗版本pve装备进阶路线,从大侠到新赛季毕业
- 盲僧|LOL手游盲僧是英雄代表?灵药再推进阶教学,双区王者的经验
- 进阶|永劫无间:胡桃只是奶妈?法神开发胡桃进阶打法,化身团战关键手
- 德鲁伊|魔兽怀旧服:TBC德鲁伊进阶宏,熊德无缝吃药,奶德一键迅捷治疗
- 进阶|梦幻西游:两次就进阶110灵性成功!难道中途的转折起了关键作用
- 进阶|梦幻西游手游:萌新的福利?新NPC开启测试,进阶不再问老玩家!
- 明日方舟|三国志战略版:冲桃园扫麒麟,虎臣弓进阶虎臣爆头骑指南
- 和平精英|和平精英核电站打法进阶教学,KS小雪吖提供详细攻略,吃鸡稳了