Thanks Kyle.
On 2020/09/09 14:20:30, Kyle Weaver wrote:
> > 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 Sr
> 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
wrote:
> Hi,
>
> How do we enable checkpointing for Flink Runner?
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,
