Hi Encho, Flink does not provide Pubsub connector. I believe you are using Beam's coder for PubsubIO. If this is correct, I guess you might want to ask this question on Beam's mailing list.
Regards, Dawid On 10/09/18 17:24, Encho Mishinev wrote: > Hello, > > I have a simple question - when does the Flink Runner for Apache Beam > acknowledge Pubsub messages when using PubsubIO? > > Thanks
signature.asc
Description: OpenPGP digital signature
