[jira] [Created] (FLINK-22708) Propagate savepoint settings from StreamExecutionEnvironment to StreamGraph

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

[jira] [Created] (FLINK-22708) Propagate savepoint settings from StreamExecutionEnvironment to StreamGraph

Shang Yuanchun (Jira)
Dawid Wysakowicz created FLINK-22708:
----------------------------------------

             Summary: Propagate savepoint settings from StreamExecutionEnvironment to StreamGraph
                 Key: FLINK-22708
                 URL: https://issues.apache.org/jira/browse/FLINK-22708
             Project: Flink
          Issue Type: Improvement
          Components: API / DataStream
            Reporter: Dawid Wysakowicz
            Assignee: Dawid Wysakowicz
             Fix For: 1.14.0, 1.13.1, 1.12.5


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:

{code}
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);
{code}

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



--
This message was sent by Atlassian Jira
(v8.3.4#803005)