Uploaded image for project: 'Flink'
  1. Flink
  2. FLINK-22708

Propagate savepoint settings from StreamExecutionEnvironment to StreamGraph

    XMLWordPrintableJSON

    Details

      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.

        Attachments

          Issue Links

            Activity

              People

              • Assignee:
                dwysakowicz Dawid Wysakowicz
                Reporter:
                dwysakowicz Dawid Wysakowicz
              • Votes:
                0 Vote for this issue
                Watchers:
                1 Start watching this issue

                Dates

                • Created:
                  Updated:
                  Resolved: