开发者社区 > 大数据与机器学习 > 实时计算 Flink > 正文

flink run -savepoint以后,jobmanager重启以后flinkid会变化吗?

flink run -savepoint以后,jobmanager重启以后flinkid会变化吗?大佬们

展开
收起
cuicuicuic 2023-10-18 16:25:23 40 0
2 条回答
写回答
取消 提交回答
  • 在 Apache Flink 中,当你运行 flink run -s 以保存一个 Savepoint 时,Savepoint 的路径和 ID 会与特定的 Flink 作业和作业管理器 (JobManager) 版本相关。这意味着如果你保存了一个 Savepoint,并且后续重启了 JobManager,Savepoint 的 ID 可能会发生变化。

    具体来说,Savepoint 的 ID 是基于 Flink 版本、作业的名称和作业的唯一 ID 生成的。如果你重启了 JobManager,特别是在升级 Flink 版本后,保存的 Savepoint 可能不再与新的 JobManager 兼容,因此其 ID 可能会发生变化。

    因此,在重启 JobManager 后,你应该将保存的 Savepoint 的路径和 ID 与新的 Flink 作业和 JobManager 版本一起使用,并确保它们仍然有效。不同的 Flink 版本和配置更改可能会影响 Savepoint 的兼容性,所以需要谨慎管理 Savepoints 来确保它们可以成功用于作业的恢复。

    2023-10-21 16:46:09
    赞同 展开评论 打赏
  • 是的,当你使用-savepoint选项运行Flink job后,如果JobManager重启,那么新的Flink ID将会改变。这是因为Flink ID是基于当前的JobManager的地址生成的,当JobManager重启后,其地址会发生改变,因此生成的Flink ID也会改变。

    如果你在重启JobManager后希望继续使用原来的Flink ID,你可以使用-fromSavepoint选项重新运行你的job,这样就会使用原来的Flink ID。

    需要注意的是,使用-savepoint-fromSavepoint选项需要在你的Flink job中配置了checkpoint。

    2023-10-19 14:19:33
    赞同 展开评论 打赏

实时计算Flink版是阿里云提供的全托管Serverless Flink云服务,基于 Apache Flink 构建的企业级、高性能实时大数据处理系统。提供全托管版 Flink 集群和引擎,提高作业开发运维效率。

相关产品

  • 实时计算 Flink版
  • 相关电子书

    更多
    Flink CDC Meetup PPT - 龚中强 立即下载
    Flink CDC Meetup PPT - 王赫 立即下载
    Flink CDC Meetup PPT - 覃立辉 立即下载