Hi Alexey Actually, I don't understand why you thing KeyedCoProcessFunction#processElement1 would block for significant amount of time, it just process record from the elements in the first input stream which is necessary. If you really find it would block for a long time, I think that's because your processing logic has some problem to stuck. On the other hand, since processing checkpoint and records hold the same lock, we cannot process checkpoint when the record processing logic did not release the lock.
Best Yun Tang ________________________________ From: Alexey Trenikhun <yen...@msn.com> Sent: Thursday, January 23, 2020 13:04 To: user@flink.apache.org <user@flink.apache.org> Subject: Blocking KeyedCoProcessFunction.processElement1 Hello, If KeyedCoProcessFunction.processElement1 blocks for significant amount of time, will it prevent checkpoint ? Thanks, Alexey
