Elasticsearch sink suppport

2024-03-18 Thread Tauseef Janvekar
Dear Team, We are using flink 1.17.2 as of now and we use elasticsearch. Any version greater than 1.17 does not support elasticsearch sink connector or as a matter of fact any connector like mongodb, opensearch, cassandra, etc.. Is there any reason for this? What should we do to upgrade to 1.18

Re: [ANNOUNCE] Apache Flink 1.19.0 released

2024-03-18 Thread Yu Li
Congrats and thanks all for the efforts! Best Regards, Yu On Tue, 19 Mar 2024 at 11:51, gongzhongqiang wrote: > > Congrats! Thanks to everyone involved! > > Best, > Zhongqiang Gong > > Lincoln Lee 于2024年3月18日周一 16:27写道: >> >> The Apache Flink community is very happy to announce the release of A

Re: [ANNOUNCE] Apache Flink 1.19.0 released

2024-03-18 Thread gongzhongqiang
Congrats! Thanks to everyone involved! Best, Zhongqiang Gong Lincoln Lee 于2024年3月18日周一 16:27写道: > The Apache Flink community is very happy to announce the release of Apache > Flink 1.19.0, which is the fisrt release for the Apache Flink 1.19 series. > > Apache Flink® is an open-source stream pr

Re: [ANNOUNCE] Apache Flink 1.19.0 released

2024-03-18 Thread Weihua Hu
Congratulations Best, Weihua On Tue, Mar 19, 2024 at 10:56 AM Rodrigo Meneses wrote: > Congratulations > > On Mon, Mar 18, 2024 at 7:43 PM Yu Chen wrote: > > > Congratulations! > > Thanks to release managers and everyone involved! > > > > Best, > > Yu Chen > > > > > > > 2024年3月19日 01:01,J

Re: [ANNOUNCE] Apache Flink 1.19.0 released

2024-03-18 Thread Yu Chen
Congratulations! Thanks to release managers and everyone involved! Best, Yu Chen > 2024年3月19日 01:01,Jeyhun Karimov 写道: > > Congrats! > Thanks to release managers and everyone involved. > > Regards, > Jeyhun > > On Mon, Mar 18, 2024 at 9:25 AM Lincoln Lee wrote: > >> The Apache Flink commu

Re: Question around manually setting Flink jobId

2024-03-18 Thread Venkatakrishnan Sowrirajan
Thanks for the response, Asimansu. I should have been a bit more clearer and shared some additional context on our internal deployment. Currently, we are running *Flink in YARN application mode* for *batch* execution purposes (we also run it for stream execution as well). In the YARN application m

Re: Help with using multiple Windows in the Table API

2024-03-18 Thread Nick Hecht
Thank you! looking though that helped me figure out what i needed to do! at first i was nervous because the docs you sent me are using the SQL approach and i wanted to use the python code i had, but the i noticed the the example SQL it was passing rowtime from one window to another. I determine

Re: [ANNOUNCE] Apache Flink 1.19.0 released

2024-03-18 Thread Jeyhun Karimov
Congrats! Thanks to release managers and everyone involved. Regards, Jeyhun On Mon, Mar 18, 2024 at 9:25 AM Lincoln Lee wrote: > The Apache Flink community is very happy to announce the release of Apache > Flink 1.19.0, which is the fisrt release for the Apache Flink 1.19 series. > > Apache Fli

Re: [ANNOUNCE] Apache Flink 1.19.0 released

2024-03-18 Thread Ron liu
Congratulations Best, Ron Yanfei Lei 于2024年3月18日周一 20:01写道: > Congrats, thanks for the great work! > > Sergey Nuyanzin 于2024年3月18日周一 19:30写道: > > > > Congratulations, thanks release managers and everyone involved for the > great work! > > > > On Mon, Mar 18, 2024 at 12:15 PM Benchao Li > wrot

Re: [ANNOUNCE] Apache Flink 1.19.0 released

2024-03-18 Thread Yanfei Lei
Congrats, thanks for the great work! Sergey Nuyanzin 于2024年3月18日周一 19:30写道: > > Congratulations, thanks release managers and everyone involved for the great > work! > > On Mon, Mar 18, 2024 at 12:15 PM Benchao Li wrote: >> >> Congratulations! And thanks to all release managers and everyone >> i

Re: [ANNOUNCE] Apache Flink 1.19.0 released

2024-03-18 Thread Sergey Nuyanzin
Congratulations, thanks release managers and everyone involved for the great work! On Mon, Mar 18, 2024 at 12:15 PM Benchao Li wrote: > Congratulations! And thanks to all release managers and everyone > involved in this release! > > Yubin Li 于2024年3月18日周一 18:11写道: > > > > Congratulations! > > >

Re: [ANNOUNCE] Apache Flink 1.19.0 released

2024-03-18 Thread Benchao Li
Congratulations! And thanks to all release managers and everyone involved in this release! Yubin Li 于2024年3月18日周一 18:11写道: > > Congratulations! > > Thanks to release managers and everyone involved. > > On Mon, Mar 18, 2024 at 5:55 PM Hangxiang Yu wrote: > > > > Congratulations! > > Thanks releas

Re: Read configmap data in FlinkDeployment

2024-03-18 Thread Yaroslav Tkachenko
This looks like an indentation error, just indent everything by two extra spaces after line 13. On Mon, Mar 18, 2024 at 3:19 AM Suyash Jaiswal wrote: > Hi Yaroslav, > > > > Thanks for the swift reply, I understand that it goes under *podTemplate, > *but can I get some sample where configmap is u

Re: [ANNOUNCE] Apache Flink 1.19.0 released

2024-03-18 Thread Yubin Li
Congratulations! Thanks to release managers and everyone involved. On Mon, Mar 18, 2024 at 5:55 PM Hangxiang Yu wrote: > > Congratulations! > Thanks release managers and all involved! > > On Mon, Mar 18, 2024 at 5:23 PM Hang Ruan wrote: > > > Congratulations! > > > > Best, > > Hang > > > > Paul

Re: Temporal join on rolling aggregate

2024-03-18 Thread Sebastien
Hi everyone, Before digging into what it would it take to implement a general solution, I narrowed down the scope to write a fix which makes the query mentioned in the thread work. Here are some findings: - For the temporal join logic, it's not the watermark that matters but having a TimeIndic

Re: Read configmap data in FlinkDeployment

2024-03-18 Thread Yaroslav Tkachenko
Hi Suyash, You can expose your configmap values as environment variables using the *podTemplate* parameter (see: https://nightlies.apache.org/flink/flink-kubernetes-operator-docs-release-1.8/docs/custom-resource/reference/). This can be configured individually for TaskManager, JobManager or for bo

Read configmap data in FlinkDeployment

2024-03-18 Thread Suyash Jaiswal
Hi All, I was trying to deploy Apache-Flink in my EKS cluster. I can successfully deploy it, but now I want to expose some variable via the configmap, these variables are used by my sessionjob. I need help with yaml structure of how/where to expose the configmap variables to make It visible for

Re: [ANNOUNCE] Apache Flink 1.19.0 released

2024-03-18 Thread Zakelly Lan
Congratulations! Thanks Lincoln, Yun, Martijn and Jing for driving this release. Thanks everyone involved. Best, Zakelly On Mon, Mar 18, 2024 at 5:05 PM weijie guo wrote: > Congratulations! > > Thanks release managers and all the contributors involved. > > Best regards, > > Weijie > > > Leona

Re: [ANNOUNCE] Apache Flink 1.19.0 released

2024-03-18 Thread weijie guo
Congratulations! Thanks release managers and all the contributors involved. Best regards, Weijie Leonard Xu 于2024年3月18日周一 16:45写道: > Congratulations, thanks release managers and all involved for the great > work! > > > Best, > Leonard > > > 2024年3月18日 下午4:32,Jingsong Li 写道: > > > > Congratu

Re: [ANNOUNCE] Apache Flink 1.19.0 released

2024-03-18 Thread Leonard Xu
Congratulations, thanks release managers and all involved for the great work! Best, Leonard > 2024年3月18日 下午4:32,Jingsong Li 写道: > > Congratulations! > > On Mon, Mar 18, 2024 at 4:30 PM Rui Fan <1996fan...@gmail.com> wrote: >> >> Congratulations, thanks for the great work! >> >> Best, >> Rui

Re: [ANNOUNCE] Apache Flink 1.19.0 released

2024-03-18 Thread Jark Wu
Congrats! Thanks Lincoln, Jing, Yun and Martijn driving this release. Thanks all who involved this release! Best, Jark On Mon, 18 Mar 2024 at 16:31, Rui Fan <1996fan...@gmail.com> wrote: > Congratulations, thanks for the great work! > > Best, > Rui > > On Mon, Mar 18, 2024 at 4:26 PM Lincoln Le

Re: [ANNOUNCE] Apache Flink 1.19.0 released

2024-03-18 Thread Jingsong Li
Congratulations! On Mon, Mar 18, 2024 at 4:30 PM Rui Fan <1996fan...@gmail.com> wrote: > > Congratulations, thanks for the great work! > > Best, > Rui > > On Mon, Mar 18, 2024 at 4:26 PM Lincoln Lee wrote: >> >> The Apache Flink community is very happy to announce the release of Apache >> Flink

Re: [ANNOUNCE] Apache Flink 1.19.0 released

2024-03-18 Thread Rui Fan
Congratulations, thanks for the great work! Best, Rui On Mon, Mar 18, 2024 at 4:26 PM Lincoln Lee wrote: > The Apache Flink community is very happy to announce the release of Apache > Flink 1.19.0, which is the fisrt release for the Apache Flink 1.19 series. > > Apache Flink® is an open-source

[ANNOUNCE] Apache Flink 1.19.0 released

2024-03-18 Thread Lincoln Lee
The Apache Flink community is very happy to announce the release of Apache Flink 1.19.0, which is the fisrt release for the Apache Flink 1.19 series. Apache Flink® is an open-source stream processing framework for distributed, high-performing, always-available, and accurate data streaming applicat