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

Reply via email to