> But, from the configuration, there is no way to pass the checkpoint interval.
Set the checkpointingInterval pipeline option. https://beam.apache.org/documentation/runners/flink/ On Wed, Sep 9, 2020 at 4:44 AM Sruthi Sree Kumar <[email protected]> wrote: > Hi, > > How do we enable checkpointing for Flink Runner? To enable checkpointing, > we set the checkpoint interval But, from the configuration, there is no way > to pass the checkpoint interval. > > We are trying to enable checkpointing while running NEXMark queries as > part of our experiments. > > -- > Regards, > > Sruthi > >
