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<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.

Reply via email to