Hi, I'm not sure about beam, but Flink is not officially compatible with python3.10.
https://nightlies.apache.org/flink/flink-docs-release-1.14/docs/dev/python/installation/ > Python version (3.6, 3.7 or 3.8) is required for PyFlink. On Fri, Jan 27, 2023 at 11:50 PM P Singh <bigdatadevelop...@gmail.com> wrote: > Hi, > > It’s not working with flink 1.14 and beam 2.44 or 2.43 with python 3.10. > > Please suggest. > > Get Outlook for iOS <https://aka.ms/o0ukef> > ------------------------------ > *From:* Yaroslav Tkachenko <yaros...@goldsky.com> > *Sent:* Friday, January 27, 2023 10:53:49 PM > *To:* P Singh <bigdatadevelop...@gmail.com> > *Cc:* user@flink.apache.org <user@flink.apache.org> > *Subject:* Re: Which flink version is compatible with beam > > 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. > >
