From a2e363615481d81f230d0f6b29d2f296c6a4a7a0 Mon Sep 17 00:00:00 2001 From: Chris Cornwell Date: Wed, 4 Aug 2021 16:10:01 -0600 Subject: [PATCH] [BEAM-12725] Pass null for schemaUpdateOptions when writing temp tables during BigQuery batch loads, schema update options are invalid --- .../java/org/apache/beam/sdk/io/gcp/bigquery/BatchLoads.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/BatchLoads.java b/sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/BatchLoads.java index 16b96bf870c7..beb1c7829271 100644 --- a/sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/BatchLoads.java +++ b/sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/BatchLoads.java @@ -696,7 +696,7 @@ private PCollection> writeTempTables( kmsKey, rowWriterFactory.getSourceFormat(), useAvroLogicalTypes, - schemaUpdateOptions)) + null)) .setCoder(KvCoder.of(tableDestinationCoder, WriteTables.ResultCoder.INSTANCE)); }