[jira] [Created] (FLINK-14054) Enable checkpointing via job configuration

classic Classic list List threaded Threaded
1 message Options
Reply | Threaded
Open this post in threaded view
|

[jira] [Created] (FLINK-14054) Enable checkpointing via job configuration

Shang Yuanchun (Jira)
Jun Qin created FLINK-14054:
-------------------------------

             Summary: Enable checkpointing via job configuration
                 Key: FLINK-14054
                 URL: https://issues.apache.org/jira/browse/FLINK-14054
             Project: Flink
          Issue Type: Improvement
          Components: Runtime / Configuration
            Reporter: Jun Qin


Currently enabling checkpointing can only be done via the job code, see the following quote from this Flink [checkpointing|https://ci.apache.org/projects/flink/flink-docs-release-1.9/dev/stream/state/checkpointing.html#enabling-and-configuring-checkpointing] doc:
{quote}By default, checkpointing is disabled. To enable checkpointing, call {{enableCheckpointing(n)}} on the {{StreamExecutionEnvironment}}, where _n_ is the checkpoint interval in milliseconds.
{quote}
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.



--
This message was sent by Atlassian Jira
(v8.3.2#803003)