[jira] [Created] (FLINK-13566) Support checkpoint configuration through flink-conf.yaml

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

[jira] [Created] (FLINK-13566) Support checkpoint configuration through flink-conf.yaml

Shang Yuanchun (Jira)
Gyula Fora created FLINK-13566:
----------------------------------

             Summary: Support checkpoint configuration through flink-conf.yaml
                 Key: FLINK-13566
                 URL: https://issues.apache.org/jira/browse/FLINK-13566
             Project: Flink
          Issue Type: New Feature
          Components: Runtime / Checkpointing, Runtime / Configuration
            Reporter: Gyula Fora


Currently basic checkpointing configuration happens through the StreamExecutionEnvironment and the CheckpointConfig class.

There is no way to configure checkpointing behaviour purely from the flink-conf.yaml file (or provide a default checkpointing behaviour) as it always needs to happen programmatically through the environment.

The checkpoint config settings are then translated down to the CheckpointCoordinatorConfiguration which will control the runtime behaviour.

As checkpointing related settings are operational features that should not affect the application logic I think we need to support configuring these params through the flink-conf yaml.

In order to do this we probably need to rework the CheckpointConfig class so that it distinguishes parameters that the user actually set from the defaults (to support overriding what was set in the conf).



--
This message was sent by Atlassian JIRA
(v7.6.14#76016)