Skip to content

Commit

Permalink
fix: Use specified bigQueryWriteClient when creating JsonStreamWriter (
Browse files Browse the repository at this point in the history
…#2711)

Fixes: #2678.
  • Loading branch information
meltsufin authored Apr 8, 2024
1 parent 71bb4a5 commit 21657a7
Showing 1 changed file with 1 addition and 1 deletion.
Original file line number Diff line number Diff line change
Expand Up @@ -78,7 +78,7 @@ public class BigQueryJsonDataWriter implements AutoCloseable {
// For more information about JsonStreamWriter, see:
// https://googleapis.dev/java/google-cloud-bigquerystorage/latest/com/google/cloud/bigquery/storage/v1beta2/JsonStreamWriter.html
streamWriter =
JsonStreamWriter.newBuilder(writeStream.getName(), writeStream.getTableSchema()).build();
JsonStreamWriter.newBuilder(writeStream.getName(), writeStream.getTableSchema(), bigQueryWriteClient).build();
this.bigQueryWriteClient = bigQueryWriteClient;
}

Expand Down

0 comments on commit 21657a7

Please sign in to comment.