Re: [VOTE] FLIP-313: Add support of User Defined AsyncTableFunction

I just realized this FLIP has never been voted to pass. +1 to the FLIP. This is actually something long overdue. I feel it is even more like a bug that we need to fix than a feature. Thanks, Jiangjie (Becket) Qin On Sun, Jun 25, 2023 at 7:36 PM Aitozi wrote: > Hi devs: > The last comments

[jira] [Created] (FLINK-37831) Failed index operations are not retried when using flink-connector-elasticsearch8 ver. 3.1.0-1.20 with flink ver. 1.20.1

Thomas Bay created FLINK-37831: -- Summary: Failed index operations are not retried when using flink-connector-elasticsearch8 ver. 3.1.0-1.20 with flink ver. 1.20.1 Key: FLINK-37831 URL: https://issues.apache.org/jira/

[jira] [Created] (FLINK-37830) Restore checkpoint state in the ES connector fails with NPE on ArrayList when using flink-connector-elasticsearch8 ver. 3.1.0-1.20 with flink ver. 1.20.1

Thomas Bay created FLINK-37830: -- Summary: Restore checkpoint state in the ES connector fails with NPE on ArrayList when using flink-connector-elasticsearch8 ver. 3.1.0-1.20 with flink ver. 1.20.1 Key: FLINK-37830 UR

Re: [DISCUSS] FLIP-531: Initiate Flink Agents as a new Sub-Project

It is great to see that everyone in this thread agreed with the high-level proposal. Just so excited and could not stop asking questions :-) Thanks Xintong for the update! I'd like to share a little bit more thoughts with my questions and your additional input. And then lead to a small suggestion.

Re: [DISCUSS] FLIP-505: Flink History Server Scability Improvements, Remote Data Store Fetch and Per Job Fetch

Hi Becket, Thank you for your feedback. I have updated the FLIP-505 proposal to reflect these comments. Would appreciate any additional feedback. Best, - Allison Chang On Tue, May 13, 2025 at 10:27 AM Becket Qin wrote: > Thanks for the FLIP, Allison. The proposal makes a lot of sense in gener

[jira] [Created] (FLINK-37828) Enable scan.incremental.snapshot.unbounded-chunk-first by default for improved stability.

JunboWang created FLINK-37828: - Summary: Enable scan.incremental.snapshot.unbounded-chunk-first by default for improved stability. Key: FLINK-37828 URL: https://issues.apache.org/jira/browse/FLINK-37828 P

Potential regression in Flink CDC 3.4.0 mysql

Hi! I tried switching an application from Flink CDC version 3.3.0 to Flink CDC version 3.4.0 and encountered the following exception: (using flink-sql-connector-mysql-cdc and flink 1.20) java.lang.RuntimeException: SplitFetcher thread 0 received unexpected exception while polling the records

[jira] [Created] (FLINK-37829) ChangelogNormalize fails with CURRENT_WATERMARK in the filter condition

Dawid Wysakowicz created FLINK-37829: Summary: ChangelogNormalize fails with CURRENT_WATERMARK in the filter condition Key: FLINK-37829 URL: https://issues.apache.org/jira/browse/FLINK-37829 Proje

[DISCUSS] Migrate state processor API from source v1 to source v2 API

Hi All, I've just had a look at it how it would be possible to migrate state processor API from source v1 to source v2 API. The whole concept in the state processor API actual implementation is based on to get RuntimeContext from RichInputFormat [1] which then allows us to access state backend, k

Re: Potential regression in Flink CDC 3.4.0 mysql

Hi Egor, Thanks for reporting this! There is some changes in MySQL binlog offset comparing logic in FLINK-37191[1]. The MySQL binlog filename comparison code (which isn’t null-safe) throwing an NPE has been there for a long time, but the execution flow might have changed and triggers this probl

[jira] [Created] (FLINK-37835) MySQL CDC BinlogOffset compareTo method throws NPE

yux created FLINK-37835: --- Summary: MySQL CDC BinlogOffset compareTo method throws NPE Key: FLINK-37835 URL: https://issues.apache.org/jira/browse/FLINK-37835 Project: Flink Issue Type: Bug Co

[jira] [Created] (FLINK-37832) Allow update checkpoint interval in update resource-requirements api

Zhenqiu Huang created FLINK-37832: - Summary: Allow update checkpoint interval in update resource-requirements api Key: FLINK-37832 URL: https://issues.apache.org/jira/browse/FLINK-37832 Project: Flink

[jira] [Created] (FLINK-37833) Code generated for binary key in BatchExecExchange causes incorrect shuffle

Venkata krishnan Sowrirajan created FLINK-37833: --- Summary: Code generated for binary key in BatchExecExchange causes incorrect shuffle Key: FLINK-37833 URL: https://issues.apache.org/jira/browse/FLIN

[jira] [Created] (FLINK-37834) Flink JDBC support ClickHouse Dialect

Arsene created FLINK-37834: -- Summary: Flink JDBC support ClickHouse Dialect Key: FLINK-37834 URL: https://issues.apache.org/jira/browse/FLINK-37834 Project: Flink Issue Type: New Feature C

[jira] [Created] (FLINK-37837) Always Add create.table to include.schema.changes option

Yanquan Lv created FLINK-37837: -- Summary: Always Add create.table to include.schema.changes option Key: FLINK-37837 URL: https://issues.apache.org/jira/browse/FLINK-37837 Project: Flink Issue Ty

[RESULT][VOTE] FLIP-486: Introduce a new DeltaJoin

Hi, devs. I'm glad to announce that FLIP-486: Introduce a new DeltaJoin[1] has been approved with 7 approving votes (4 binding)[2]. - Ron Liu (binding) - Xiangyu (non-binding) - Weijie (binding) - CaoZhen (non-binding) - Lincoln Lee (binding) - Gustavo (non-binding) - Jark (binding) T

[jira] [Created] (FLINK-37836) FLIP-486 Introduce a new DeltaJoin

Xuyang Zhong created FLINK-37836: Summary: FLIP-486 Introduce a new DeltaJoin Key: FLINK-37836 URL: https://issues.apache.org/jira/browse/FLINK-37836 Project: Flink Issue Type: New Feature

Re: [DISCUSS] FLIP-531: Initiate Flink Agents as a new Sub-Project

@Jing, I think the FLIP already included the high-level design goals, by listing the key features that we plan to support in the Proposed Solution section, and demonstrating how using the framework may look like with the code examples. Of course the high-level goals need to be further detailed, wh