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

Flink这个错是并行度太小吗?

Flink这个错是并行度太小吗?failureraterestartbackofftimestrategy

展开
收起
真的很搞笑 2023-11-06 12:08:02 62 0
1 条回答
写回答
取消 提交回答
  • 面对过去,不要迷离;面对未来,不必彷徨;活在今天,你只要把自己完全展示给别人看。

    不是这样的。FailureRateRestartBackOffTimeStrategy是Flink的一个重启策略,它会在任务失败率达到一定阈值时自动重启任务。这与并行度无关。

    例如,如果你设置了FailureRateRestartBackOffTimeStrategy的阈值为50%,并且你的任务并行度为10,则当任务中有五个任务失败时,Flink会自动重启任务。重启后的任务将在一段时间内再次尝试运行,如果再次失败,则会再次重启,直到达到最大的重试次数。

    你可以在Flink的配置中设置这个参数,如下所示:

    restart-strategy.failure-rate.attempts: number of attempts
    restart-strategy.failure-rate.delay: delay between restarts in ms
    restart-strategy.failure-rate.max-delay: maximum delay between restarts in ms
    restart-strategy.failure-rate.retry-once-per-interval: time interval to wait before restarting the job after an exception has been thrown
    

    你还可以在Java API中使用RestartStrategies.failureRateWithBackoff()方法来设置这个参数。

    2023-11-06 13:38:52
    赞同 1 展开评论 打赏

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

相关产品

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

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