Skip to content
Permalink
Browse files
fix: call awaitTermination when close the stream writer (#1111)
  • Loading branch information
yirutang committed Jun 5, 2021
1 parent 4a95b95 commit 0f7db50bdd8f653f8087550cb2d1eeb47975eadf
Showing with 4 additions and 0 deletions.
  1. +4 −0 ...cloud-bigquerystorage/src/main/java/com/google/cloud/bigquery/storage/v1beta2/StreamWriterV2.java
@@ -317,6 +317,10 @@ public void close() {
}
if (this.ownsBigQueryWriteClient) {
this.client.close();
try {
this.client.awaitTermination(1, TimeUnit.MINUTES);
} catch (InterruptedException ignored) {
}
}
}

0 comments on commit 0f7db50

Please sign in to comment.