beam-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Josh <>
Subject Re: How to skip processing on failure at BigQueryIO sink?
Date Tue, 11 Apr 2017 08:12:23 GMT
What I really want to do is configure BigQueryIO to log an error and skip
the write if it receives a 4xx response from BigQuery (e.g. element does
not match table schema). And for other errors (e.g. 5xx) I want it to retry
n times with exponential backoff.

Is there any way to do this at the moment? Will I need to make some custom
changes to BigQueryIO?

On Mon, Apr 10, 2017 at 7:11 PM, Josh <> wrote:

> Hi,
> I'm using BigQueryIO to write the output of an unbounded streaming job to
> BigQuery.
> In the case that an element in the stream cannot be written to BigQuery,
> the BigQueryIO seems to have some default retry logic which retries the
> write a few times. However, if the write fails repeatedly, it seems to
> cause the whole pipeline to halt.
> How can I configure beam so that if writing an element fails a few times,
> it simply gives up on writing that element and moves on without affecting
> the pipeline?
> Thanks for any advice,
> Josh

View raw message