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 <[email protected]> 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 <[email protected]> > *Sent:* Friday, January 27, 2023 10:53:49 PM > *To:* P Singh <[email protected]> > *Cc:* [email protected] <[email protected]> > *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 <[email protected]> > 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. > >
