Hi,

I have a Dataflow pipeline with PubSub UnboundedSource, The pipeline
transforms the data and writes to another PubSub topic. I have a question
regarding exceptions in DoFns. If I chose to ignore an exception processing
an element, does it ACK the bundle?
Also if I were to just throw the exception, my understanding is the
Dataflow Runner will fail the whole bundle and keeps retrying until the
whole bundle is successful am I correct?

Thanks for your response

Reply via email to