[FLINK-22708] Propagate savepoint settings from StreamExecutionEnvironment to StreamGraph

• Type: Improvement
• Status: Closed
• Priority: Major
• Resolution: Fixed
• Fix Version/s: 1.14.0, 1.13.1, 1.12.5
• Component/s: API / DataStream
• Labels: pull-request-available
• Assignee: Dawid Wysakowicz
• Reporter: Dawid Wysakowicz
• Created: 19/May/21 07:20
• Updated: 28/Aug/21 12:10
• Resolved: 21/May/21 09:24

Description

Currently, if you configure SavepointSettings in the initial Configuration passed to StreamExecutionEnvironment it is not passed to the StreamGraphGenerator. Therefore a chain of calls will not apply these settings:

Configuration conf = new Configuration();
conf.set(SavepointConfigOptions.SAVEPOINT_PATH, "/tmp/savepoint");

StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment(conf);
StreamGraph graph = env.getStreamGraph();
JobGraph jobGraph = graph.getJobGraph();

miniCluste.submitJob(jobGraph);

This makes the UnalignedCheckpointRescaleITCase not testing what it is supposed to test.

Issue Links

• links to: GitHub Pull Request #15953