Hello, I am using Flink runner with Apache Beam 2.6.0. I was wondering if there is information on when exactly the runner acknowledges a pubsub message when reading from PubsubIO?
My problem is that whenever there are a few messages left in a subscription my streaming job never really seems to acknowledge them all. For example is a subscription has 100,000,000 messages in total, the job will go through about 99,990,000 and then keep reading the last few thousand and seemingly never acknowledge them. Some clarity on when the acknowledgement happens in the pipeline might help me debug this problem. Thanks!
