[ 
https://issues.apache.org/jira/browse/BEAM-12356?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17382232#comment-17382232
 ] 

Jeff Klukas commented on BEAM-12356:
------------------------------------

I also have just observed a recurrence of this issue in a Dataflow pipeline 
running Java SDK 2.31.0. We had previously downgraded to 2.28.0 waiting for 
this fix. It looks to be less frequent than it was on 2.29.0, but is still 
happening.

> BigQueryWriteClient in DatasetServiceImpl is not closed, which causes 
> "ManagedChannel allocation site" exceptions
> -----------------------------------------------------------------------------------------------------------------
>
>                 Key: BEAM-12356
>                 URL: https://issues.apache.org/jira/browse/BEAM-12356
>             Project: Beam
>          Issue Type: Bug
>          Components: io-java-gcp
>    Affects Versions: 2.29.0
>            Reporter: Minbo Bae
>            Assignee: Reuven Lax
>            Priority: P2
>             Fix For: 2.31.0
>
>         Attachments: bigquery_grpc.log
>
>          Time Spent: 2h 20m
>  Remaining Estimate: 0h
>
> [BigQueryWriteClient|https://github.com/apache/beam/blob/v2.29.0/sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/BigQueryServicesImpl.java#L461]
>  in DatasetServiceImpl (added at [https://github.com/apache/beam/pull/14309)] 
> is not closed.  This causes the error logs  in gRPC orphan channel clean up. 
> See "bigquery_grpc.log" in attachments which is extracted from GCP Dataflow. 
> I don't think this issue affect pipeline runs except the error logs, but 
> could you take a look at that?
> A similar issue is reported for {{CloudBigtableIO}} at 
> [https://github.com/googleapis/java-bigtable-hbase/issues/2658]
>  



--
This message was sent by Atlassian Jira
(v8.3.4#803005)

Reply via email to