Hi All, Thanks for your help in advance. I am using async I/O with flink 1.5.5, I am using
AsyncDataStream.unorderedWait method also my capacity is set to 100.My question is since my capacity is 100, each thread will be processing one record.Say sequence number of my records is S1,S2....S100 and say at a particular point in time , thread T1 is processing record S1, T2 is processing record S2 and T100 is processing record S100 and say all the threads T1..T100 except T50 failed when sending the record to the Sink. In this will the checkpoint pointer move at all or not. Apologies in advance if my question is not clear. Thanks, Anurag
