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]<mailto:[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.

Reply via email to