In ExecutionGraph.java when configuring the checkpoint stats tracker the config values are read from the jobConfiguration:
The settings are only available in the Flink Configuration, however. Right now, the ExecutionGraph has no access to the Flink Configuration.
I see three solutions:
- pass the Flink Configuration to the ExecutionGraph
- pass just the two required settings to the ExecutionGraph
- Introduce a new ExecutionGraphSettings that contains settings only for the ExecutionGraph in order to clean up things a bit