I suspect this may be due to long-standing bugs regarding forking a
process that has grpc channels. See, e.g.
https://github.com/grpc/grpc/issues/18321
On Wed, Feb 26, 2020 at 9:02 AM laxman reddy wrote:
>
> Hello Team,
> i am using beam for experimenting for my project usecase
>
Hello Team,
i am using beam for experimenting for my project usecase
i have specific steps for a pipeline. for each step to process i am using do
function in pardo invocation in pipeline
in one of the steps i had implemented multiprocessing implemented
with out multiprocessing t
