[jira] [Created] (FLINK-37903) Support runtime config for ML_PREDICT

Shengkai Fang created FLINK-37903: - Summary: Support runtime config for ML_PREDICT Key: FLINK-37903 URL: https://issues.apache.org/jira/browse/FLINK-37903 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-37901) Support to serde ExecNode for ML_PREDICT

Shengkai Fang created FLINK-37901: - Summary: Support to serde ExecNode for ML_PREDICT Key: FLINK-37901 URL: https://issues.apache.org/jira/browse/FLINK-37901 Project: Flink Issue Type: Sub-ta

[jira] [Created] (FLINK-37902) Support batch execution for ML_PREDICT

Shengkai Fang created FLINK-37902: - Summary: Support batch execution for ML_PREDICT Key: FLINK-37902 URL: https://issues.apache.org/jira/browse/FLINK-37902 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-37900) Support configurable jitter in rocksdb checkpoint file uploader

Zhenqiu Huang created FLINK-37900: - Summary: Support configurable jitter in rocksdb checkpoint file uploader Key: FLINK-37900 URL: https://issues.apache.org/jira/browse/FLINK-37900 Project: Flink

Flink CDC for mongoDB, need to understand MongoDBStreamFetchTask better

Hi, I seem to have some difficulty in understanding the code for: https://github.com/apache/flink-cdc/blob/master/flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mongodb-cdc/src/main/java/org/apache/flink/cdc/connectors/mongodb/source/reader/fetch/MongoDBStreamFetchTask.java#L95 Out

[jira] [Created] (FLINK-37899) Unstable JoinRestoreTest

Shengkai Fang created FLINK-37899: - Summary: Unstable JoinRestoreTest Key: FLINK-37899 URL: https://issues.apache.org/jira/browse/FLINK-37899 Project: Flink Issue Type: Bug Componen

Waiting on approval to Jira account

Hi team, I requested a Jira account 3 days ago, and I've not received an update since. I hope to contribute a bug fix to the Flink Kinesis connector. How long does the approval process usually take? username: digitalpoetry Thank you, Jonathan Du

[jira] [Created] (FLINK-37897) Support converting a regular join to a delta join for the simplest pattern in planner

Xuyang Zhong created FLINK-37897: Summary: Support converting a regular join to a delta join for the simplest pattern in planner Key: FLINK-37897 URL: https://issues.apache.org/jira/browse/FLINK-37897

[jira] [Created] (FLINK-37898) Implement delta join operator

Xuyang Zhong created FLINK-37898: Summary: Implement delta join operator Key: FLINK-37898 URL: https://issues.apache.org/jira/browse/FLINK-37898 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-37896) Introduce a new trait derived from sink to source that verifies whether the downstream node can accept redundant data generated by a delta join.

Xuyang Zhong created FLINK-37896: Summary: Introduce a new trait derived from sink to source that verifies whether the downstream node can accept redundant data generated by a delta join. Key: FLINK-37896 URL: ht

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

Hi Swapnal, Thanks for your feedback. Haven't discussed this with the others yet, but A2A is at least on my list. But I haven't thought about it in detail enough to answer your questions. Our plan is to first work on a MVP version that shows the unique advantages and differentiators of Flink Ag

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

+1 (non-binding) Sounds exciting! I went through the FLIP and it mentions support for MCP (for tools) and kafka as a storage engine for inter agent interaction support. These are great for enterprise adoption, standardization, and interoperability! In similar vein, I wanted to get the community'

Re: [DISCUSS] FLIP-533: Cassandra Sink V2

Hi Etienne, Thank you for talking out the time to review the FLIP: Please find the responses inline below: > > - config: usually in Flink we use factories to build from configuration > rather than a visitor pattern which is quite associated with tree/graph > or any collection to visit. > Thanks

Re: [DISCUSS] FLIP-533: Cassandra Sink V2

Hi all, Thanks Poorvank for your work. Some quick comments: *phase1 design:* - config: usually in Flink we use factories to build from configuration rather than a visitor pattern which is quite associated with tree/graph or any collection to visit. - parallel writes : what is the instanci

Re: Request a permission

Hi Gustavo, Thank you for your response, I have an account now. Best, Zhe Wang Gustavo de Morais 于2025年6月3日周二 23:22写道： > Hey Zhe Wang, > > If you'd to file new Jira tickets, head over to the self-serve apache > portal > to create an account. > Af

Re: [DISCUSS] FLIP-533: Cassandra Sink V2

On Wed, Jun 4, 2025 at 7:40 AM Poorvank Bhatia wrote: > Hi all, > Following the earlier discussion on modernizing the Cassandra Sink (initial > thread >), > FLIP-533 > < > https://cwiki.apache.org/confluence/display/FLINK/FLIP-53

[DISCUSS] FLIP-533: Cassandra Sink V2

Hi all, Following the earlier discussion on modernizing the Cassandra Sink (initial thread ), FLIP-533 has now been created: This FLIP proposes a two-

[jira] [Created] (FLINK-37895) "Failed to fetch job exceptions from REST API for jobId" errors for session jobs

Sebastian Struß created FLINK-37895: --- Summary: "Failed to fetch job exceptions from REST API for jobId" errors for session jobs Key: FLINK-37895 URL: https://issues.apache.org/jira/browse/FLINK-37895

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

+1 (binding) On Wed, Jun 4, 2025 at 5:21 PM Jiangang Liu wrote: > +1 (non-binding) > > Feng Jin 于2025年6月4日周三 16:12写道： > > > +1 (binding) > > > > Best, > > Feng Jin > > > > > > On Wed, Jun 4, 2025 at 1:51 PM Yun Tang wrote: > > > > > +1 (binding) > > > > > > > > > Best, > > > Yun Tang > > > ___

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

+1 (binding) Best, Feng Jin On Wed, Jun 4, 2025 at 1:51 PM Yun Tang wrote: > +1 (binding) > > > Best, > Yun Tang > > From: Gustavo de Morais > Sent: Wednesday, June 4, 2025 0:25 > To: dev@flink.apache.org > Subject: Re: [VOTE] FLIP-531: Initiate Flink Agents

[ANNOUNCE] Apache Flink Kubernetes Operator 1.12.0 released

The Apache Flink community is very happy to announce the release of Apache Flink Kubernetes Operator 1.12.0. The Flink Kubernetes Operator allows users to manage their Apache Flink applications and their lifecycle through native k8s tooling like kubectl. Please check out the release blog post for

Re: [DISCUSS] FLIP-523 - Handle TLS Certificate Renewal

Hi, I've read it through. Basically looks good with one comment. *registerWatchedPath function* has a *Callable* as callback. For the current implementation that would be enough, but when somebody would like to use that for any other use-case then it would be hard. Examples: * A single *call* func

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

+1 (non-binding) Feng Jin 于2025年6月4日周三 16:12写道： > +1 (binding) > > Best, > Feng Jin > > > On Wed, Jun 4, 2025 at 1:51 PM Yun Tang wrote: > > > +1 (binding) > > > > > > Best, > > Yun Tang > > > > From: Gustavo de Morais > > Sent: Wednesday, June 4, 2025 0:25 > >

[jira] [Created] (FLINK-37892) SplitFetcherManagerTest#testCloseBlockingWaitingForFetcherShutdown azure cron ci failed

dalongliu created FLINK-37892: - Summary: SplitFetcherManagerTest#testCloseBlockingWaitingForFetcherShutdown azure cron ci failed Key: FLINK-37892 URL: https://issues.apache.org/jira/browse/FLINK-37892 P

[jira] [Created] (FLINK-37893) Rest Port Name should be made configurable

Mayur Dhingra created FLINK-37893: - Summary: Rest Port Name should be made configurable Key: FLINK-37893 URL: https://issues.apache.org/jira/browse/FLINK-37893 Project: Flink Issue Type: Impr

[jira] [Created] (FLINK-37894) Introduce new Join Operator with Async State API

Wang Qilong created FLINK-37894: --- Summary: Introduce new Join Operator with Async State API Key: FLINK-37894 URL: https://issues.apache.org/jira/browse/FLINK-37894 Project: Flink Issue Type: Su

Re: [DISCUSS] FLIP-529 Connections in Flink SQL and Table API

Hey，Mayank Please see my feedback as following: 1. One of the motivations of this FLIP is to improve security. However, the current design stores all connection information in the catalog, and each Flink SQL job reads from the catalog during compilation. The connection information is passed be

Re: [DISCUSS] Proposal: Modernizing Cassandra Sink with Sink V2 & Async Support

Poorvank, It sounds like a great plan ! Thanks I created a FLIP for your proposal: https://cwiki.apache.org/confluence/display/FLINK/FLIP-533%3A+Cassandra+Sink+V2 Please open a thread named /[DISCUSS] FLIP-533 Cassandra Sink V2 /to hold the discussion on the design. FYI: here is the FLIP p

[SUMMARY] Flink 2.1 Release Sync 06/04/2025

Hi, devs, This is the fourth meeting for Flink 2.1 release cycle. I'd like to share the information synced in the meeting. - Feature Freeze It is worth noting that there are only 2 weeks left until the feature freeze time(June 21, 2025), and developers need to pay attention to the feature fre