[jira] [Created] (FLINK-38279) Failed to restore job when using MySQL Source with scan.startup.mode=snapshot in streaming mode

2025-08-22 Thread Yanquan Lv (Jira)
Yanquan Lv created FLINK-38279: -- Summary: Failed to restore job when using MySQL Source with scan.startup.mode=snapshot in streaming mode Key: FLINK-38279 URL: https://issues.apache.org/jira/browse/FLINK-38279

Re: [DISCUSS] FLIP-490: Enhanced Job History Retention Policies for HistoryServer

2025-08-22 Thread Becket Qin
Hi Yuepeng, I think it would be better to keep the configurations straight forward instead of conditional if possible. How about just adding one config of TTL. We will remove a job archive either when its TTL has passed, or when the retained job count has been reached and the job is the earliest j

[ANNOUNCE] Apache flink-connector-kafka 4.0.1 release

2025-08-22 Thread Fabian Paul
The Apache Flink community is very happy to announce the release of Apache flink-connector-kafka 4.0.1. Apache Flink® is an open-source stream processing framework for distributed, high-performing, always-available, and accurate data streaming applications. The release is available for download a

Re: [DISCUSS] FLIP-495: Support AdaptiveScheduler record and query the rescale history

2025-08-22 Thread Roc Marshal
Hi, Matthias. Thank you very much for the comments. > - Why do we mark the rescale operation as IGNORED if an (repeatable) > exception causes a restart? Here we mainly discuss two scenarios: - If a recoverable exception occurs while there is an ongoing rescale, the current rescale will be forci

[jira] [Created] (FLINK-38278) PostgresSQL supported array field types.

2025-08-22 Thread ouyangwulin (Jira)
ouyangwulin created FLINK-38278: --- Summary: PostgresSQL supported array field types. Key: FLINK-38278 URL: https://issues.apache.org/jira/browse/FLINK-38278 Project: Flink Issue Type: Improveme

Re: [DISCUSS] FLIP-490: Enhanced Job History Retention Policies for HistoryServer

2025-08-22 Thread Yuepeng Pan
Would anyone like to discuss this FLIP? I'd appreciate your feedback and suggestions. Best, Yuepeng Pan On 2025/08/20 07:13:44 Yuepeng Pan wrote: > Hi, Becket. > > Thank you for the clarification. > Please let me have a try on revisiting these two questions with a explanation: > > > I meant to

[RESULT][VOTE] FLIP-540: Support VECTOR_SEARCH in Flink SQL

2025-08-22 Thread Shengkai Fang
Hi Dev, I'm happy to announce that FLIP-540: Support VECTOR_SEARCH in Flink SQL[1] has been accepted with 10 approving votes (4 binding) [2]. There are no disapproving votes. Timo Walther (binding) dylanhz (non-binding) Weiqing Yang (non-binding) Mingge Deng (non-binding) Hao Li (non-binding) Lin

Re:Re: [VOTE] FLIP-540: Support VECTOR_SEARCH in Flink SQL

2025-08-22 Thread Xuyang
+1(binding) -- Best! Xuyang 在 2025-08-21 11:25:50,"Shengkai Fang" 写道: >+1(binding) > >Best, >Shengkai > >Yash Anand 于2025年8月20日周三 11:17写道: > >> +1 (non-binding) >> >> Thanks, >> Yash >> >> On Tue, Aug 19, 2025 at 7:03 PM Jacky Lau wrote: >> >> > +1 (non-binding) >> > >> > Best re

Re: [DISCUSS] FLIP-XXX: Hardening the Event Reporter with an Asynchronous Core

2025-08-22 Thread Kartikey Pant
Hi Aleksandr, Thanks for the great feedback. Your points on guaranteed delivery and the *FileEventsReporter* are spot on, and I agree with your reasoning. I'll update the FLIP to incorporate them, as it will make the proposal much stronger. Regarding the delivery guarantee, I'll add a new configu