[ https://issues.apache.org/jira/browse/BEAM-14283?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Anonymous updated BEAM-14283: ----------------------------- Status: Triage Needed (was: Resolved) > Reduce number of threads spawned by BigqueryIO StreamingInserts > --------------------------------------------------------------- > > Key: BEAM-14283 > URL: https://issues.apache.org/jira/browse/BEAM-14283 > Project: Beam > Issue Type: Improvement > Components: io-java-gcp > Reporter: Arun Pandian > Assignee: Arun Pandian > Priority: P2 > Fix For: 2.39.0 > > Time Spent: 1h 20m > Remaining Estimate: 0h > > BigqueryIO's BoundedExecutorService is creating many new threads. It can be > optimized by acquiring the involved semaphore before task submission instead > of after inside the runnable. > ref:https://github.com/apache/beam/blob/5603bd310a63fa35082e6bc6b06c7fecc90e77d7/sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/BigQueryServicesImpl.java#L1676 -- This message was sent by Atlassian Jira (v8.20.10#820010)