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 <bigdatadevelop...@gmail.com> Date: 28/01/2023 10:20 (GMT+05:30) To: Yaroslav Tkachenko <yaros...@goldsky.com> 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 <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.
