请问 flink作业从checkpoint恢复是下列哪种情况?[阿里云实时计算 Flink版]

问一下 flink作业从checkpoint恢复是先把状态从磁盘读到jobmaster内存再分发给各个task还是,直接由各个taskmanager读自己的那一份状态到内存啊?

「点点赞赏,手留余香」

    还没有人赞赏,快来当第一个赞赏的人吧!
=====这是一个广告位,招租中,联系qq 78315851====
1 条回复 A 作者 M 管理员
  1. 从 checkpoint 恢复状态时,首先将 checkpoint 数据从持久化存储(如 HDFS)中读入 JobManager 的内存,然后 JobManager 将该状态数据分配给各个 TaskManager,最后每个 TaskManager 会在其本地的磁盘中读取自己的那一份状态数据并将其加载到内存中。这样可以避免在恢复状态时将整个状态数据集发送到各个 TaskManager,从而提高恢复速度和效率。

  2. jobmaster是将状态的元数据信息发给task,task自己去对应位置读。此答案出自钉群“【③群】Apache Flink China社区”