I did a simple fix for this issue here:
https://github.com/apache/beam/pull/9364
Tested locally and it fixes the problem. Can someone help take a look?
Thanks,
Hai
On Thu, Aug 15, 2019 at 9:16 AM Hai Lu wrote:
> Hi,
>
> This is Hai from LinkedIn.
>
> I'm looking into a bug I found internally
Hi,
This is Hai from LinkedIn.
I'm looking into a bug I found internally when using Beam portable API
(Python) on our own Samza runner.
The pipeline looks something like this:
(p
| 'read' >> ReadFromKafka(cluster="tracking", topic="PageViewEvent")
| 'transform' >> beam.Map(lambda
