Hi,All
I am using
parquetio<https://beam.apache.org/releases/javadoc/2.5.0/org/apache/beam/sdk/io/parquet/ParquetIO.html>
as the source component in our batch pipeline and the pipeline is running in
flink runner, we want to enable checkpoint for the pipeline so it can resume
while there is failure happening on flink cluster, is this possible since it is
a batch pipeline ?
Thanks,
Ivan
