[beam] branch master updated: restore deleted line

[tvalentyn]

This is an automated email from the ASF dual-hosted git repository.

tvalentyn pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git


The following commit(s) were added to refs/heads/master by this push:
     new 755ce7b43f1 restore deleted line
     new dced7738d6a Merge pull request #26089 from reuvenlax/fix_storage_api
755ce7b43f1 is described below

commit 755ce7b43f1e1b3b6fcc069ec8c97a50bc6d28c6
Author: Reuven Lax <re...@google.com>
AuthorDate: Mon Apr 3 21:11:27 2023 -0700

    restore deleted line
---
 .../apache/beam/sdk/io/gcp/bigquery/StorageApiWriteUnshardedRecords.java | 1 +
 1 file changed, 1 insertion(+)

diff --git 
a/sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/StorageApiWriteUnshardedRecords.java
 
b/sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/StorageApiWriteUnshardedRecords.java
index e01a93957b6..f0015cddc38 100644
--- 
a/sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/StorageApiWriteUnshardedRecords.java
+++ 
b/sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/StorageApiWriteUnshardedRecords.java
@@ -473,6 +473,7 @@ public class StorageApiWriteUnshardedRecords<DestinationT, 
ElementT>
 
         final ProtoRows.Builder insertsBuilder = ProtoRows.newBuilder();
         insertsBuilder.addAllSerializedRows(pendingMessages);
+        pendingMessages.clear();
         final ProtoRows inserts = insertsBuilder.build();
         List<org.joda.time.Instant> insertTimestamps = pendingTimestamps;
         pendingTimestamps = Lists.newArrayList();