Versions Compared

Key

  • This line was added.
  • This line was removed.
  • Formatting was changed.

...

Current stateUnder Discussion

Discussion thread: https://lists.apache.org/thread.html/e206390127bcbd9b24d9c41a838faa75157e468e01552ad241e3e24b@%3Cdev.flink.apache.org%3E

JIRA: FLINK-13921

Released:

...

I would like to simplify the configuration by removing the "If `restart-strategy.fixed-delay.attempts` or `restart-strategy.fixed-delay.delay`, then" condition. That way, the logic would be the following:

  • If the config option `restart-strategy` is configured, then Flink uses this `RestartStrategy`
  • If the config option `restart-strategy` is not configured, then 
    • If checkpointing is disabled, then choose `NoRestartStrategy`
    • If checkpointing is enabled, then choose `FixedDelayRestartStrategy(Integer.MAX_VALUE, "0 s")`

That way we retain the user friendliness that jobs restart if the user enabled checkpointing and we make it clear that any `restart-strategy.fixed-delay.xyz` setting will only be respected if `restart-strategy` has been set to `fixed-delay`.

...