This is an automated email from the ASF dual-hosted git repository. reuvenlax pushed a commit to branch release-2.45.0 in repository https://gitbox.apache.org/repos/asf/beam.git
commit ade83b355eed496c7e23606ab63e86eddd1d3988 Merge: 7d07ffe68ba 7f6c93ea039 Author: Reuven Lax <re...@google.com> AuthorDate: Fri Jan 27 08:41:58 2023 -0800 Merge pull request #25205: Cherry pick/fix bigquery inconsistent cache .../beam/sdk/io/gcp/bigquery/AppendClientInfo.java | 120 ++++++++++-- .../beam/sdk/io/gcp/bigquery/BigQueryIO.java | 18 +- .../beam/sdk/io/gcp/bigquery/BigQueryServices.java | 8 + .../sdk/io/gcp/bigquery/BigQueryServicesImpl.java | 11 ++ .../beam/sdk/io/gcp/bigquery/BigQueryUtils.java | 29 --- .../sdk/io/gcp/bigquery/SplittingIterable.java | 61 +++++- .../bigquery/StorageApiDynamicDestinations.java | 2 + .../StorageApiDynamicDestinationsBeamRow.java | 8 +- .../StorageApiDynamicDestinationsTableRow.java | 24 ++- .../beam/sdk/io/gcp/bigquery/StorageApiLoads.java | 20 +- .../io/gcp/bigquery/StorageApiWritePayload.java | 25 ++- .../StorageApiWriteRecordsInconsistent.java | 12 +- .../bigquery/StorageApiWriteUnshardedRecords.java | 146 +++++++++++--- .../bigquery/StorageApiWritesShardedRecords.java | 173 +++++++++++------ .../io/gcp/bigquery/TableRowToStorageApiProto.java | 110 +++++++++-- .../sdk/io/gcp/testing/FakeDatasetService.java | 63 +++++- .../sdk/io/gcp/bigquery/BigQueryIOWriteTest.java | 216 +++++++++++++++++++++ .../bigquery/TableRowToStorageApiProtoTest.java | 95 ++++++++- 18 files changed, 968 insertions(+), 173 deletions(-)