You are viewing a plain text version of this content. The canonical link for it is here.

Posted to user@beam.apache.org by "Peng, Ivan" <sh...@ebay.com> on 2022/05/13 00:46:24 UTC

[Question] - Flink Runner Savepoint Enabling

Hi,
      Have read through below doc but can’t find an option to enable savepoint : https://beam.apache.org/documentation/runners/flink/ , the question is how can we schedule savepoint automatically through apache beam pipeline that using flink runner ?
Thanks,
Ivan

Re: [Question] - Flink Runner Savepoint Enabling

Posted by Deepak Nagaraj <de...@primer.ai>.

Hi Ivan,

Did you mean to take an automatic savepoint or checkpoint? A savepoint is
usually manual and initiated during (for example) Flink version upgrade or
Flink job update. [1]

You can set Flink checkpoint interval with Beam's Flink runner.

Thanks,
Deepak

[1]
https://nightlies.apache.org/flink/flink-docs-release-1.14/docs/ops/state/savepoints/

On Thu, May 12, 2022 at 5:46 PM Peng, Ivan <sh...@ebay.com> wrote:

> Hi,
>
>       Have read through below doc but can’t find an option to enable
> savepoint : https://beam.apache.org/documentation/runners/flink/ , the
> question is how can we schedule savepoint automatically through apache beam
> pipeline that using flink runner ?
>
> Thanks,
>
> Ivan
>
>
>