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

这个重启次数是什么时候会增加?flink会自动重启吗?重启会产生新的jobId吗?

这个重启次数是什么时候会增加?flink会自动重启吗?重启会产生新的jobId吗?52b6ac0bfe4e3772b3501ee68990e835.png

展开
收起
三分钟热度的鱼 2023-11-22 19:47:50 128 0
3 条回答
写回答
取消 提交回答
  • 在Apache Flink中,重启次数是在任务失败并且需要重试时才会增加。Flink提供了故障恢复机制,可以在任务失败时自动重新运行任务,直到成功为止。因此,只有当任务失败并且需要重试时,重启次数才会增加。

    至于JobId,Flink在创建新的Job时,会为每个Job生成一个唯一的JobId。如果Job失败并进行了重启,那么同一个Job会使用相同的JobId。如果需要创建新的Job,那么将会生成新的JobId。

    2023-11-28 10:58:15
    赞同 展开评论 打赏
  • 面对过去,不要迷离;面对未来,不必彷徨;活在今天,你只要把自己完全展示给别人看。

    Flink 的重启次数是在任务失败并且需要重试时才会增加。Flink 提供了故障恢复机制,可以在任务失败时自动重新运行任务,直到成功为止。因此,只有当任务失败并且需要重试时,重启次数才会增加。
    关于 jobId,Flink 的 jobId 是唯一标识一个任务的身份,即使任务被重试也会保留相同的 jobId。因此,无论任务失败多少次并被重试,都不会产生新的 jobId,而是始终使用相同的 jobId。
    总的来说,Flink 的重启次数只会随着任务失败和重试而增加,而且任务的 jobId 不会发生变化,除非你手动停止任务并且重新启动它,这时将会生成一个新的 jobId。

    2023-11-22 22:01:53
    赞同 展开评论 打赏
  • failover 此回答整理自钉群“实时计算Flink产品交流群”

    2023-11-22 19:53:34
    赞同 展开评论 打赏

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

相关产品

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

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