Re: Go SDK pubsubio.Write does not output anything running on Dataflow

2022-05-10 Thread Hannes Gustafsson
This issue is still present on v2.38.0 for us, and we're working around it using a custom sink and the upstream PubSub API client directly. I've now had a chance to experiment further and have made some progress. Based on trial and error, it seems that the pubsubio.Write transform does not seri

Re: Beam slowness compared to flink-native

2022-05-10 Thread Talat Uyarer
HI Ifat, Did you enable fasterCopy parameter ? Please look at this issue: https://issues.apache.org/jira/browse/BEAM-11146 Thanks On Mon, May 2, 2022 at 12:57 AM Afek, Ifat (Nokia - IL/Kfar Sava) < ifat.a...@nokia.com> wrote: > Hi, > > > > I’m investigating a slowness of our beam pipelines, an