[ANNOUNCE] Apache Flink Kafka Connectors 3.0.2 released

The Apache Flink community is very happy to announce the release of Apache Flink Kafka Connectors 3.0.2. This release is compatible with the Apache Flink 1.17.x and 1.18.x release series. Apache Flink® is an open-source stream processing framework for distributed, high-performing, always-available

[jira] [Created] (FLINK-33725) MathUtils.isPowerOf2 does not cover the case of value=0

Jes Cok created FLINK-33725: --- Summary: MathUtils.isPowerOf2 does not cover the case of value=0 Key: FLINK-33725 URL: https://issues.apache.org/jira/browse/FLINK-33725 Project: Flink Issue Type: Im

[jira] [Created] (FLINK-33724) Application mode doesn't support multiple lines argument

Jiaxing Chen created FLINK-33724: Summary: Application mode doesn't support multiple lines argument Key: FLINK-33724 URL: https://issues.apache.org/jira/browse/FLINK-33724 Project: Flink Issu

[jira] [Created] (FLINK-33723) Disallow triggering incremental checkpoint explicitly from REST API

Zakelly Lan created FLINK-33723: --- Summary: Disallow triggering incremental checkpoint explicitly from REST API Key: FLINK-33723 URL: https://issues.apache.org/jira/browse/FLINK-33723 Project: Flink

[jira] [Created] (FLINK-33722) MATCH_RECOGNIZE in batch mode ignores events order

Grzegorz Kołakowski created FLINK-33722: --- Summary: MATCH_RECOGNIZE in batch mode ignores events order Key: FLINK-33722 URL: https://issues.apache.org/jira/browse/FLINK-33722 Project: Flink

Re: [DISCUSS] Resolve diamond inheritance of Sink.createWriter

Thanks Becket for your reply! *On Option 1:* - I personally consider API inconsistencies more important, since they will remain with us "forever", but this is up to the community. I can implement whichever solution we decide upon. *Option 2:* - I don't think this specific issue merits a rewrite,

Re: Doc about cleaning savePoints and checkPoints

Hi, Rodrigo It appears that the configurations you mentioned in your first question are related to the flink kubernetes operator. Are you using the flink kubernetes operator? In regards to the cleaning behavior when users restore a job from a savepoint or retained checkpoint, you can find detaile

[jira] [Created] (FLINK-33721) Extend BashJavaUtils to Support Reading and Writing Standard YAML Files

Junrui Li created FLINK-33721: - Summary: Extend BashJavaUtils to Support Reading and Writing Standard YAML Files Key: FLINK-33721 URL: https://issues.apache.org/jira/browse/FLINK-33721 Project: Flink

Re: [VOTE] FLIP-364: Improve the restart-strategy

+1 (binding) On Fri, Dec 1, 2023 at 3:40 AM Zhu Zhu wrote: > +1 (binding) > > Thanks, > Zhu > > Zhanghao Chen 于2023年11月30日周四 23:31写道： > > > +1 (non-binding) > > > > Best, > > Zhanghao Chen > > > > From: Rui Fan <1996fan...@gmail.com> > > Sent: Monday, November 1