Checkpoint自动恢复

Checkpoint自动恢复也就是自动从Checkpoint恢复状态，开启checkpoint后配置应用的自动重启策略。

自动重启策略被设计成了四种方式：

1. 默认重启策略:如果配置Checkpoint，没有配置重启策略，那么代码中出现了非致命错误时，程序会无限重启。

2. 无重启策略:Job直接失败，不会尝试进行重启。

   1. 全局配置flink-conf.yaml，对所有job有效。

      xxxxxxxxxx
      restart-strategy: none
      

   2. 程序配置，对当前job有效

      xxxxxxxxxx
      env.setRestartStrategy(RestartStrategies.noRestart())
      

3. 固定延迟重启策略:设置固定重启次数，及重启间隔时间。【开发中常用】

   程序异常时，自动重启。如果设置最大重启次数，且重启超过设置次数，需要人为干预，进行手动重启。

   1. 全局配置flink-conf.yaml，对所有job有效。

      xxxxxxxxxx
      restart-strategy: fixed-delay
      restart-strategy.fixed-delay.attempts: 3
      restart-strategy.fixed-delay.delay: 10s
      

   2. 程序配置，对当前job有效

      xxxxxxxxxx
      env.setRestartStrategy(RestartStrategies.fixedDelayRestart(
        3,//最多重启次数
        Time.of(10,TimeUnit.SECONDS)//重启间隔时间
      ))
      

4. 失败率重启策略【偶尔使用】

   如果4分钟内job失败不超过3次，自动重启，每次间隔10秒；如果4分钟内job失败超过3次,则程序退出。

   1. 全局配置flink-conf.yaml，对所有job有效。

      xxxxxxxxxx
      restart-strategy: failure-rate
      restart-strategy.failure-rate-pre-interval: 3
      restart-strategy.failure-rate-interval: 4min
      restart-strategy.failure-rate.delay: 10s
      

   2. 程序配置，对当前job有效

      xxxxxxxxxx
      env.setRestartStrategy(RestartStrategies.failureRateRestart(
        3,//每个测量间隔内最大失败次数
        Time.of(4,TimeUnit.MINUTES),//失败率测量的时间间隔
        Time.of(10,TimeUnit.SECONDS)//两次连续重启的间隔时间
      ))