You are viewing a plain text version of this content. The canonical link for it is here.
Posted to user@flink.apache.org by P Singh <bi...@gmail.com> on 2023/01/27 17:19:29 UTC
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.
Re: Which flink version is compatible with beam
Posted by Andrew Otto <ot...@wikimedia.org>.
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 <bi...@gmail.com>
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 <ya...@goldsky.com>
> *Sent:* Friday, January 27, 2023 10:53:49 PM
> *To:* P Singh <bi...@gmail.com>
> *Cc:* user@flink.apache.org <us...@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 <bi...@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
Posted by P Singh <bi...@gmail.com>.
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 <ya...@goldsky.com>
Sent: Friday, January 27, 2023 10:53:49 PM
To: P Singh <bi...@gmail.com>
Cc: user@flink.apache.org <us...@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 <bi...@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
Posted by Yaroslav Tkachenko <ya...@goldsky.com>.
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 <bi...@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.
>
>