I can see it was very recently added... https://issues.apache.org/jira/browse/BEAM-5372
On Wed, Sep 12, 2018 at 12:54 PM Encho Mishinev <[email protected]> wrote: > Hello, > > I am using Flink runner with Apache Beam 2.6.0. An important configuration > of Flink is the 'minimum time between checkpoints' parameter in addition to > just the checkpointing interval. This is important since if checkpoints are > heavy, the job might end up doing mostly checkpointing and not actual work. > > Is there a way to configure this option in the Flink runner? Unfortunately > it's not configurable through flink's configuration .yaml file so there > must be a way to configure it through Beam. > > Thanks, > Encho >
