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

flink 可以让他自动重启的时候都无状态重启吗?

flink 可以让他自动重启的时候都无状态重启吗?

展开
收起
三分钟热度的鱼 2023-12-06 19:21:19 188 0
3 条回答
写回答
取消 提交回答
  • 是的,Flink 可以在自动重启时以无状态方式重启。为了实现这一点,你需要在 Flink job 的配置中设置 "restart-strategy" 为 "fixed-delay" 策略,并将 "failover-mode" 设置为 "standby"。这样,当任务失败并自动重启时,它们将无状态地启动,即不会保留任何先前运行的状态。

    以下是一个简单的示例,展示了如何在 Flink job 中配置固定延迟重启策略和备用故障转移模式:

    job.setRestartStrategy(RestartStrategies.fixedDelayRestart(
        int restartAttempts,
        long delayBetweenAttempts));
    
    job.setFailoverStrategy(FailoverStrategies.standbyMode());
    

    在这个配置中,restartAttempts 参数表示在任务失败后尝试重启的次数,而 delayBetweenAttempts 参数表示两次重启尝试之间的延迟(以毫秒为单位)。

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

    是的,Flink确实支持无状态重启。你可以通过在flink-conf.yaml文件中设置restart-strategy为none来启用无状态重启策略。此外,无重启策略也可以在程序中设置。需要注意的是,无重启策略意味着如果任务失败,Job将直接失败,而不会尝试进行重启。

    2023-12-06 21:30:38
    赞同 展开评论 打赏
  • 目前还不行。此回答整理自钉群“实时计算Flink产品交流群”

    2023-12-06 20:22:29
    赞同 展开评论 打赏

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

相关产品

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

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