I'm unfamiliar with configuring Flink to run Beam jobs, but AFAIK it's up to
the runner to orchestrate/set up properly configured workers with the
containers. With Beam, there should never be any need to manually set up
workers for Flink, etc to run on.
Those flags/etc are part of the "beam co
Hi Danny,
Thank you for the provided information.
Best regards,
Ayoyinka.
On Mon, Mar 20, 2023 at 1:53 PM Danny McCormick via user <
user@beam.apache.org> wrote:
> Hey Ayoyinka,
>
> That PR with protobuf>=4.21.1,<4.23.0 support should be included in the
> 2.47 release, that is correct.
>
> The
Hi Apache Beam team,
I hope this email finds you all well. I have been experimenting with Apache
Beam and Flink, mainly using golang. I hit a roadblock when trying to run
the minimal word count example on Beam and Flink locally using Go SDK
workers. I am trying to use the "apache/beam_go_sdk:2.46.
