Hi Talat, Can you elaborate on what it means to create one checkpoint object per chain operator more than all operators? If you mean to do checkpoint independently for each task, this is not supported.
Best regards, Weijie Talat Uyarer via user <user@flink.apache.org> 于2023年2月1日周三 15:34写道： > 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 >
