[FLINK-14054] Enable checkpointing via job configuration

• Type: Improvement
• Status: Closed
• Priority: Major
• Resolution: Fixed
• Fix Version/s: 1.10.0
• Component/s: Runtime / Checkpointing, Runtime / Configuration
• Assignee: Unassigned
• Reporter: Jun Qin
• Created: 11/Sep/19 16:20
• Updated: 24/Aug/20 13:03
• Resolved: 24/Aug/20 13:03

Description

Currently enabling checkpointing can only be done via the job code, see the following quote from this Flink checkpointing doc:

By default, checkpointing is disabled. To enable checkpointing, call enableCheckpointing on the StreamExecutionEnvironment, where n is the checkpoint interval in milliseconds.

This makes enabling checkingpointing after the job code has been released difficult: one has to change and rebuild the job code.

In addition, not only for developer, making checkpointing enabling configurable is also of interest for operation teams:

• They may want to enable checkpointing for production but disable in test (e.g., to save storage space)
• They may want to try out with and without checkpointing to evaluate the impact to the job behaviour and performance.  

Therefore, this request.  Thanks.