Hi,

We have a job that is reading from kafka and writing some endpoints. The
job does not have any shuffling steps.  I implement it with multiple
steps.  Flink chained those operators in one operator in submission time.
However I see all operators are doing checkpointing.

Is there any way to create one checkpoint object per chain operator rather
than all operators ?

Thanks

Reply via email to