prodriguezdefino commented on code in PR #17550:
URL: https://github.com/apache/beam/pull/17550#discussion_r876248021
##########
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/StorageApiWriteUnshardedRecords.java:
##########
@@ -409,9 +447,18 @@ private void initializeDatasetService(PipelineOptions
pipelineOptions) {
}
}
+ @Setup
+ public void setup() {
Review Comment:
I've seen evidence that closing one stream append client for the `_default`
stream causes a cascade close of the other ones, so moving the state for
destinations to be reused between bundle executions at least decreased the
occurrences of those cascading closes.
I can revert this if this is not the right idea to try.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
