[Date Prev][Date Next][Thread Prev][Thread Next][Date Index][Thread Index]

Re: Acknowledging Pubsub messages in Flink Runner

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.



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

Attachment: signature.asc
Description: OpenPGP digital signature