Re: Which flink version is compatible with beam
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 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 > *Sent:* Friday, January 27, 2023 10:53:49 PM > *To:* P Singh > *Cc:* 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 > 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. > >
Re: Which flink version is compatible with beam
I have added flink:1.14 with Apache/beam:2.38.0When I submit the job python basic.py get warning:Root: make sure locally built python SDK docker image has python 3.8 interpreter. After this warning nothing is happening no logs or trace back. Please help. Sent from my Galaxy Original message From: P Singh Date: 28/01/2023 10:20 (GMT+05:30) To: Yaroslav Tkachenko Cc: user@flink.apache.org Subject: Re: Which flink version is compatible with beam 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 From: Yaroslav Tkachenko Sent: Friday, January 27, 2023 10:53:49 PM To: P Singh Cc: 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 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.
Re: Which flink version is compatible with beam
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 Sent: Friday, January 27, 2023 10:53:49 PM To: P Singh Cc: 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 mailto: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.
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 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. > >
Which flink version is compatible with beam
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.
