You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@beam.apache.org by Sruthi Sree Kumar <sr...@gmail.com> on 2020/09/09 11:44:09 UTC
Enabling checkpointing while running 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,
Sruthi
Re: Enabling checkpointing while running Flink Runner
Posted by Sruthi Sree Kumar <sr...@gmail.com>.
Thanks Kyle.
On 2020/09/09 14:20:30, Kyle Weaver <kc...@google.com> 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 Sree Kumar <sr...@gmail.com>
> 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
> >
> >
>
Re: Enabling checkpointing while running Flink Runner
Posted by Kyle Weaver <kc...@google.com>.
> 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 <sr...@gmail.com>
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
>
>