Skip to content

Commit c1d0fa4

Browse files
authored
Clarify BigQuery InsertRetryPolicy behavior for non-200 responses (#34118)
1 parent 57c644a commit c1d0fa4

File tree

1 file changed

+16
-1
lines changed

1 file changed

+16
-1
lines changed

sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/InsertRetryPolicy.java

+16-1
Original file line numberDiff line numberDiff line change
@@ -23,7 +23,22 @@
2323
import java.util.Set;
2424
import org.apache.beam.vendor.guava.v32_1_2_jre.com.google.common.collect.ImmutableSet;
2525

26-
/** A retry policy for streaming BigQuery inserts. */
26+
/**
27+
* A retry policy for streaming BigQuery inserts.
28+
*
29+
* <p>This retry policy currently applies only to per-element errors within successful (200 OK)
30+
* BigQuery responses. Non-200 responses (e.g., 400 Bad Request, 500 Internal Server Error) will
31+
* result in a {@code RuntimeException} and bundle failure. The subsequent handling of the failed
32+
* bundle (e.g., retry or final failure) is determined by the specific Runner's fault tolerance
33+
* mechanisms.
34+
*
35+
* @see org.apache.beam.sdk.io.gcp.bigquery.BigQueryServicesImpl.DatasetServiceImpl#insertAll(
36+
* TableReference, java.util.List, java.util.List, BackOff,
37+
* org.apache.beam.sdk.util.FluentBackoff, Sleeper,
38+
* org.apache.beam.sdk.io.gcp.bigquery.InsertRetryPolicy, java.util.List,
39+
* org.apache.beam.sdk.io.gcp.bigquery.ErrorContainer, boolean, boolean, boolean,
40+
* java.util.List)
41+
*/
2742
public abstract class InsertRetryPolicy implements Serializable {
2843
/**
2944
* Contains information about a failed insert.

0 commit comments

Comments
 (0)