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

Reply via email to