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 <[email protected]> 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 > > >
