[beam] branch master updated: Merge pull request #25627: #25626 Use the correct constructor when creating StreamWriter

[reuvenlax]

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

reuvenlax 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 124e1d6a5f1 Merge pull request #25627: #25626 Use the correct 
constructor when creating StreamWriter
124e1d6a5f1 is described below

commit 124e1d6a5f14dd7b194a98d43dbc771cbad05065
Author: Reuven Lax <re...@google.com>
AuthorDate: Fri Feb 24 14:52:47 2023 -0800

    Merge pull request #25627: #25626 Use the correct constructor when creating 
StreamWriter
---
 .../org/apache/beam/sdk/io/gcp/bigquery/BigQueryServicesImpl.java     | 4 +++-
 1 file changed, 3 insertions(+), 1 deletion(-)

diff --git 
a/sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/BigQueryServicesImpl.java
 
b/sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/BigQueryServicesImpl.java
index bc798c47573..040346bb910 100644
--- 
a/sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/BigQueryServicesImpl.java
+++ 
b/sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/BigQueryServicesImpl.java
@@ -1338,7 +1338,9 @@ class BigQueryServicesImpl implements BigQueryServices {
               .build();
 
       StreamWriter streamWriter =
-          StreamWriter.newBuilder(streamName)
+          StreamWriter.newBuilder(
+                  streamName,
+                  
org.apache.beam.sdk.util.Preconditions.checkStateNotNull(newWriteClient))
               .setWriterSchema(protoSchema)
               .setChannelProvider(transportChannelProvider)
               .setEnableConnectionPool(useConnectionPool)