[
https://issues.apache.org/jira/browse/BEAM-12359?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Filip Popić updated BEAM-12359:
-------------------------------
Description:
When Reading from BigQueryIO using DIRECT_READ getting
```log
*~*~*~ Channel ManagedChannelImpl\{logId=1,
target=bigquerystorage.googleapis.com:443} was not shutdown properly!!! ~*~*~*
Make sure to call shutdown()/shutdownNow() and wait until awaitTermination()
returns true.
```
Sbt/Scala minimal example to reproduce [https://github.com/fpopic/BEAM-12359]
(if required can try to make it in Java).
Relates to:
-
[https://lists.apache.org/x/thread.html/r705ca8f0ea9517f148637be59e509ce80fa75b22c98ad63acd551065@%3Cuser.beam.apache.org%3E]
was:
Sbt/Scala example to reproduce [https://github.com/fpopic/BEAM-12359] (if
required can try to make it in Java).
Relates to:
https://lists.apache.org/x/thread.html/r705ca8f0ea9517f148637be59e509ce80fa75b22c98ad63acd551065@%3Cuser.beam.apache.org%3E
> Throwing warning/error when reading by using BigQuery Storage Read API
> ----------------------------------------------------------------------
>
> Key: BEAM-12359
> URL: https://issues.apache.org/jira/browse/BEAM-12359
> Project: Beam
> Issue Type: Bug
> Components: extensions-java-gcp
> Affects Versions: 2.29.0
> Reporter: Filip Popić
> Assignee: Kenneth Jung
> Priority: P2
>
> When Reading from BigQueryIO using DIRECT_READ getting
>
> ```log
> *~*~*~ Channel ManagedChannelImpl\{logId=1,
> target=bigquerystorage.googleapis.com:443} was not shutdown properly!!!
> ~*~*~* Make sure to call shutdown()/shutdownNow() and wait until
> awaitTermination() returns true.
> ```
>
> Sbt/Scala minimal example to reproduce [https://github.com/fpopic/BEAM-12359]
> (if required can try to make it in Java).
> Relates to:
> -
> [https://lists.apache.org/x/thread.html/r705ca8f0ea9517f148637be59e509ce80fa75b22c98ad63acd551065@%3Cuser.beam.apache.org%3E]
>
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
