Skip to content

Commit 42171e7

Browse files
committed
Set default BigQuery storage stream translation state
1 parent b6cec47 commit 42171e7

1 file changed

Lines changed: 4 additions & 1 deletion

File tree

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

Lines changed: 4 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -617,7 +617,10 @@ public Write<?> fromConfigRow(Row configRow, PipelineOptions options) {
617617
(updateCompatibilityBeamVersion != null) ? updateCompatibilityBeamVersion : "2.53.0";
618618

619619
try {
620-
BigQueryIO.Write.Builder builder = new AutoValue_BigQueryIO_Write.Builder<>();
620+
BigQueryIO.Write.Builder builder =
621+
new AutoValue_BigQueryIO_Write.Builder<>()
622+
.setNumStorageWriteApiStreams(0)
623+
.setNumStorageWriteApiStreamsConfigured(false);
621624

622625
String jsonTableRef = configRow.getString("json_table_ref");
623626
if (jsonTableRef != null) {

0 commit comments

Comments
 (0)