Hi! According to this https://beam.apache.org/documentation/runners/flink/#flink-version-compatibility, 1.14 is the latest supported version.
On Fri, Jan 27, 2023 at 9:19 AM P Singh <bigdatadevelop...@gmail.com> wrote: > Hi Team, > > I am trying to run apache beam pipeline on flink cluster. I have set up > kubernetes locally with flink1.16and apache/beam_python3.10_sdk:2.44.0. > When I submit the job using like > > python file.py > > Job is just hang not able to see on flink UI or logs. > > Can you please suggest compatible versions? > > > Looking forward to hearing from you. > >
