tongchenkeji 发表于：2023-12-6 19:21:190次点击 已关注取消关注 关注 私信 flink 可以让他自动重启的时候都无状态重启吗？[阿里云] 暂停朗读为您朗读 flink 可以让他自动重启的时候都无状态重启吗？ 「点点赞赏，手留余香」 赞赏 还没有人赞赏，快来当第一个赞赏的人吧！ 海报 阿里云# 实时计算 Flink版3179# 流计算2236
sun20AM 2023-12-21 8:22:42 1 是的，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 参数表示两次重启尝试之间的延迟（以毫秒为单位）。
小周sirAM 2023-12-21 8:22:42 2 是的，Flink确实支持无状态重启。你可以通过在flink-conf.yaml文件中设置restart-strategy为none来启用无状态重启策略。此外，无重启策略也可以在程序中设置。需要注意的是，无重启策略意味着如果任务失败，Job将直接失败，而不会尝试进行重启。
是的，Flink 可以在自动重启时以无状态方式重启。为了实现这一点，你需要在 Flink job 的配置中设置 “restart-strategy” 为 “fixed-delay” 策略，并将 “failover-mode” 设置为 “standby”。这样，当任务失败并自动重启时，它们将无状态地启动，即不会保留任何先前运行的状态。
以下是一个简单的示例，展示了如何在 Flink job 中配置固定延迟重启策略和备用故障转移模式：
在这个配置中，
restartAttempts参数表示在任务失败后尝试重启的次数，而delayBetweenAttempts参数表示两次重启尝试之间的延迟（以毫秒为单位）。是的，Flink确实支持无状态重启。你可以通过在flink-conf.yaml文件中设置restart-strategy为none来启用无状态重启策略。此外，无重启策略也可以在程序中设置。需要注意的是，无重启策略意味着如果任务失败，Job将直接失败，而不会尝试进行重启。
目前还不行。此回答整理自钉群“实时计算Flink产品交流群”