[jira] [Created] (FLINK-38067) Release Testing: Verify FLIP-525: Model ML_PREDICT, ML_EVALUATE Implementation Design

2025-07-08 Thread Hao Li (Jira)
Hao Li created FLINK-38067: -- Summary: Release Testing: Verify FLIP-525: Model ML_PREDICT, ML_EVALUATE Implementation Design Key: FLINK-38067 URL: https://issues.apache.org/jira/browse/FLINK-38067 Project: Fl

[jira] [Created] (FLINK-38068) Fix distribution

2025-07-08 Thread Hao Li (Jira)
Hao Li created FLINK-38068: -- Summary: Fix distribution Key: FLINK-38068 URL: https://issues.apache.org/jira/browse/FLINK-38068 Project: Flink Issue Type: Sub-task Reporter: Hao Li

[jira] [Created] (FLINK-38069) The nullability of function ENCODE return type differs in Table API and SQL

2025-07-08 Thread Dylan He (Jira)
Dylan He created FLINK-38069: Summary: The nullability of function ENCODE return type differs in Table API and SQL Key: FLINK-38069 URL: https://issues.apache.org/jira/browse/FLINK-38069 Project: Flink

[jira] [Created] (FLINK-38070) Release Testing: Verify FLIP-507 : Add Model DDL methods in TABLE API

2025-07-08 Thread Yash Anand (Jira)
Yash Anand created FLINK-38070: -- Summary: Release Testing: Verify FLIP-507 : Add Model DDL methods in TABLE API Key: FLINK-38070 URL: https://issues.apache.org/jira/browse/FLINK-38070 Project: Flink

[DISCUSS] Add UDF Metrics

2025-07-08 Thread Weiqing Yang
Hi all, I’d like to initiate a discussion about adding UDF metrics. *Motivation* User-defined functions (UDFs) are essential for custom logic in Flink jobs but often act as black boxes, making debugging and performance tuning difficult. When issues like high latency or frequent exceptions occur,

[jira] [Created] (FLINK-38071) FLIP-485: Add UDF Metrics

2025-07-08 Thread Weiqing Yang (Jira)
Weiqing Yang created FLINK-38071: Summary: FLIP-485: Add UDF Metrics Key: FLINK-38071 URL: https://issues.apache.org/jira/browse/FLINK-38071 Project: Flink Issue Type: New Feature C

[jira] [Created] (FLINK-38064) Bump cyclonedx-maven-plugin from 2.7.7 to 2.9.1

2025-07-08 Thread Siddharth R (Jira)
Siddharth R created FLINK-38064: --- Summary: Bump cyclonedx-maven-plugin from 2.7.7 to 2.9.1 Key: FLINK-38064 URL: https://issues.apache.org/jira/browse/FLINK-38064 Project: Flink Issue Type: Imp

[jira] [Created] (FLINK-38066) Release Testing: Verify FLIP-437: Support ML Models in Flink SQL

2025-07-08 Thread Hao Li (Jira)
Hao Li created FLINK-38066: -- Summary: Release Testing: Verify FLIP-437: Support ML Models in Flink SQL Key: FLINK-38066 URL: https://issues.apache.org/jira/browse/FLINK-38066 Project: Flink Issue T

Re: [DISCUSSION] FLIP Process - Handling similar FLIPs and dormant FLIPs

2025-07-08 Thread Weiqing Yang
+1 on the overall proposal. I think these guidelines make sense for reducing confusion and respecting contributors’ work. One scenario I'd also like to discuss is when there's a discussion thread with a proposal document but no FLIP created yet - so it's still in the early discussion phase. In pra

[jira] [Created] (FLINK-38061) Caused by: java.util.ConcurrentModificationException When the MySql Chunk Split stage triggers a checkpoint

2025-07-08 Thread potterhe (Jira)
potterhe created FLINK-38061: Summary: Caused by: java.util.ConcurrentModificationException When the MySql Chunk Split stage triggers a checkpoint Key: FLINK-38061 URL: https://issues.apache.org/jira/browse/FLINK-3806

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

2025-07-08 Thread Gyula Fóra
+1 (binding) Verified: - Sources & signatures - Installed operator and ran example applications and session jobs, verified exception handling / events - Built from source Cheers, Gyula On Tue, Jul 8, 2025 at 10:07 AM Robert Metzger wrote: > ok, thanks a lot. So my +1 on the RC makes sense ;

[jira] [Created] (FLINK-38062) ENCODE behaves wrong

2025-07-08 Thread Sergey Nuyanzin (Jira)
Sergey Nuyanzin created FLINK-38062: --- Summary: ENCODE behaves wrong Key: FLINK-38062 URL: https://issues.apache.org/jira/browse/FLINK-38062 Project: Flink Issue Type: Technical Debt

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

2025-07-08 Thread Gyula Fóra
@Robert Metzger : The session clusters do not get too many events from the FKO (only things like spec change etc) but most events are job related at the moment. So this is expected, but could be improved :) Gyula On Tue, Jul 8, 2025 at 9:17 AM Robert Metzger wrote: > +1 (binding) > > - I've su

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

2025-07-08 Thread Robert Metzger
ok, thanks a lot. So my +1 on the RC makes sense ;) On Tue, Jul 8, 2025 at 10:03 AM Gyula Fóra wrote: > @Robert Metzger : > The session clusters do not get too many events from the FKO (only things > like spec change etc) but most events are job related at the moment. > So this is expected, bu

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

2025-07-08 Thread Robert Metzger
+1 (binding) - I've successfully installed the operator RC - launched a application mode job, exception events get reported properly - launched a session cluster, submitted a job. *Neither exception events, nor any other events (from FKO) get reported for the session cluster. Is this expected?* -

Flink Kubenetes Operator client version

2025-07-08 Thread David Radley
Hi, I can see that the Flink operator uses the 6.13.2 Kubenetes client . We are looking to move up to use 7.20 to pick up security fixes. I see https://github.com/fabric8io/kubernetes-client/blob/main/doc/MIGRATION-v7.md. Any thoughts on the impact and whether there is a community support for t

Re: Flink Kubenetes Operator client version

2025-07-08 Thread Gyula Fóra
Hi David! I think we should definitely pick up the latest version if possible, we have to make sure that this is compatible with how Flink uses the client for native integration though. Cheers Gyula On Tue, Jul 8, 2025 at 6:02 PM David Radley wrote: > Hi, > I can see that the Flink operator us

Re: Flink Kubenetes Operator client version

2025-07-08 Thread Tom Cooper
Hi David, I had a conversation in the dim distant past about doing this and I remember that the the main issue with the upgrade in the operator was that the main Flink repo [1] had not upgraded yet and that there could be conflicts? However, I am drawing a blank on the exact details. +1 for w

[jira] [Created] (FLINK-38063) Update dependencies in the Flink Connector Kafka Project

2025-07-08 Thread Thomas Cooper (Jira)
Thomas Cooper created FLINK-38063: - Summary: Update dependencies in the Flink Connector Kafka Project Key: FLINK-38063 URL: https://issues.apache.org/jira/browse/FLINK-38063 Project: Flink Is

[jira] [Created] (FLINK-38065) Mismatching bracket in PostgresOffset#toString

2025-07-08 Thread Sergei Morozov (Jira)
Sergei Morozov created FLINK-38065: -- Summary: Mismatching bracket in PostgresOffset#toString Key: FLINK-38065 URL: https://issues.apache.org/jira/browse/FLINK-38065 Project: Flink Issue Type