[jira] [Created] (FLINK-35655) Support more pipeline sources

linqigeng created FLINK-35655: - Summary: Support more pipeline sources Key: FLINK-35655 URL: https://issues.apache.org/jira/browse/FLINK-35655 Project: Flink Issue Type: New Feature Com

[jira] [Created] (FLINK-35654) Add Flink CDC verification guide in docs

yux created FLINK-35654: --- Summary: Add Flink CDC verification guide in docs Key: FLINK-35654 URL: https://issues.apache.org/jira/browse/FLINK-35654 Project: Flink Issue Type: Bug Components:

[jira] [Created] (FLINK-35653) "fraud detection" example missed "env.execute" explanation

Luke Chen created FLINK-35653: - Summary: "fraud detection" example missed "env.execute" explanation Key: FLINK-35653 URL: https://issues.apache.org/jira/browse/FLINK-35653 Project: Flink Issue Ty

[jira] [Created] (FLINK-35652) FLIP-462: Support Custom Data Distribution for Input Stream of Lookup Join

Weijie Guo created FLINK-35652: -- Summary: FLIP-462: Support Custom Data Distribution for Input Stream of Lookup Join Key: FLINK-35652 URL: https://issues.apache.org/jira/browse/FLINK-35652 Project: Flink

[RESULT][VOTE] FLIP-462: Support Custom Data Distribution for Input Stream of Lookup Join

Hi devs, I'm happy to announce that FLIP-462: Support Custom Data Distribution for Input Stream of Lookup Join [1] has been accepted with 5 approving votes (3 binding) [2]: - Xintong Song (binding) - Lincoln Lee (binding) - Jingsong Li (binding) - Zhanghao Chen (non-binding) - Feng Jin (no

Re: [ANNOUNCE] Flink 1.20 feature freeze

+1 for Xintong's point. Hi Ferenc, After discussing this with all the other RM's, we decided not to merge the PR you mentioned into 1.20. The main reason is that FLIP-464 was voted in three days ago, which is already after feature freeze date. It doesn't make sense to us to put it in the 1.20 rel

[jira] [Created] (FLINK-35651) Unable to call argument-less built-in functions with parentheses

yux created FLINK-35651: --- Summary: Unable to call argument-less built-in functions with parentheses Key: FLINK-35651 URL: https://issues.apache.org/jira/browse/FLINK-35651 Project: Flink Issue Type: B

Re: [ANNOUNCE] New Apache Flink Committer - Zhongqiang Gong

{ "emoji": "👍", "version": 1 }

Re: [ANNOUNCE] New Apache Flink Committer - Zhongqiang Gong

Swapnal Varma 于2024年6月18日 周二21:58写道： > Congratulations Zhongqiang! > > Best, > Swapnal > > > On Tue, 18 Jun 2024, 07:05 Jacky Lau, wrote: > > > Congratulations Zhongqiang! > > > > Best Regards > > Jacky Lau > > > > Yubin Li 于2024年6月18日周二 00:28写道： > > > > > Congratulations Zhongqiang! > > > > > >

[jira] [Created] (FLINK-35650) Incorrect TIMESTAMP_LTZ type behavior in Table SQL

Andrey Gaskov created FLINK-35650: - Summary: Incorrect TIMESTAMP_LTZ type behavior in Table SQL Key: FLINK-35650 URL: https://issues.apache.org/jira/browse/FLINK-35650 Project: Flink Issue Ty

Re: [DISCUSS] FLIP-463: Schema Definition in CREATE TABLE AS Statement

Hi Sergio, thanks for updating the FLIP and ingesting the feedback from the ML discussion. I would be fine to start voting on this, if there are no objections? Regards, Timo On 18.06.24 19:53, Sergio Pena wrote: Hi Jeyhun, Timo, I updated the FLIP to include the option to reorder the colum

Re: [ANNOUNCE] Apache Flink 1.19.1 released

Hi Rui, Thanks for flagging - this is the official docker repo, which requires action from external party to merge our PR[1] and replicate the Docker images. The Docker image is available on the ASF maintained Docker repo [2] [1] https://github.com/docker-library/official-images/pull/17013 [2] h

Re: [VOTE] Apache Flink Kubernetes Operator Release 1.9.0, release candidate #1

Hi, I have updated the KEYs file and extended the expiration date so that should not be an issue. Thanks for pointing that out. Gyula On Wed, 19 Jun 2024 at 12:07, Rui Fan <1996fan...@gmail.com> wrote: > Thanks Gyula and Mate for driving this release! > > +1 (binding) > > Except the key is expi

Re: [VOTE] Apache Flink Kubernetes Operator Release 1.9.0, release candidate #1

Thanks Gyula and Mate for driving this release! +1 (binding) Except the key is expired, and leaving a couple of comments to the flink-web PR, the rest of them are fine. - Downloaded artifacts from dist ( svn co https://dist.apache .org/repos/dist/dev/flink/flink-kubernetes-operator-1.9.0-rc1/ )

Re: [DISCUSS] FLIP-XXX: Improve JDBC connector extensibility for Table API

Hello guys and thank you for your feedback! Very well appreciated. Sorry for the late reply, but it took a lot of time to address your concerns. I had to re-design the refactor and convince myself of the best way to accomodate both rewriting existing connectors (e.g. Postgres) and new ones. Hope y

Re: [ANNOUNCE] Flink 1.20 feature freeze

Hi Ferenc, About the deprecation process, removing a @Public API requires the API to be deprecated for at least 2 minor releases AND the removal should be in a major version bump. That means you cannot remove a @Public API in 2.x when x is not 0. The tricky part is, run-application as a command-li

[jira] [Created] (FLINK-35649) Bump Flink version to 1.19.1 in k8s-operator

Ferenc Csaky created FLINK-35649: Summary: Bump Flink version to 1.19.1 in k8s-operator Key: FLINK-35649 URL: https://issues.apache.org/jira/browse/FLINK-35649 Project: Flink Issue Type: Impr