Re: [DISCUSS] State Schema Evolution for RowData

2025-05-06 Thread Hangxiang Yu
Hi, Weiqing. Thanks for driving this FLIP. I'm +1 for supporting schema evolution for SQL RowData type. I just have some questions: 1. Could we consider defining a method returning *SchemaEvolutionSerializer* in *TypeSerializerSchemaCompatibility* (like compatibleAfterMigration(TypeSerializer sche

[jira] [Created] (FLINK-37766) FlinkSessionJob deletion blocked by finalizer when Flink job already terminal/missing due to HA desync

2025-05-06 Thread Kartikey Pant (Jira)
Kartikey Pant created FLINK-37766: - Summary: FlinkSessionJob deletion blocked by finalizer when Flink job already terminal/missing due to HA desync Key: FLINK-37766 URL: https://issues.apache.org/jira/browse/FLINK

[jira] [Created] (FLINK-37765) Idea import duplicate modules error.

2025-05-06 Thread ouyangwulin (Jira)
ouyangwulin created FLINK-37765: --- Summary: Idea import duplicate modules error. Key: FLINK-37765 URL: https://issues.apache.org/jira/browse/FLINK-37765 Project: Flink Issue Type: Improvement

Re: [DISCUSS] FLIP-525: Model ML_PREDICT, ML_EVALUATE Implementation Design

2025-05-06 Thread Ron Liu
> It's mainly used for model evaluation purposes for `ML_EVALUATE`. Different loss functions will be used and different metrics will be output for `ML_EVALUATE` based on the task option of the model. Task option is not necessary if the model is not used in `ML_EVALUATE`. `ML_EVALUATE` also has an o

Re: [DISCUSS] FLIP-525: Model ML_PREDICT, ML_EVALUATE Implementation Design

2025-05-06 Thread Hao Li
Hi Yunfeng, Ron, Thanks for the feedback. > it might be better to change the configuration api_key to apikey Make sense. I updated the FLIP. > Why is it necessary to define the task option in the WITH clause of the Model DDL, and what is its purpose? It's mainly used for model evaluation purpos

Re: [VOTE] FLIP-520: Simplify StructuredType handling

2025-05-06 Thread Ron Liu
+1(binding) Best, Ron Hao Li 于2025年5月7日周三 00:08写道: > +1 (non-binding) > > Thanks for driving this! > > Hao > > On Tue, May 6, 2025 at 8:27 AM Ferenc Csaky > wrote: > > > +1 (binding) > > > > Thanks for driving this! > > > > Best, > > Ferenc > > > > > > > > > > On Tuesday, May 6th, 2025 at 14:5

Re: [VOTE] Apache Flink CDC Release 3.4.0, release candidate #3

2025-05-06 Thread Leonard Xu
+1 (binding) - verified signatures - verified hashsums - checked Github release tag - built from source code with Java 8 succeeded - checked release notes - reviewed the web PR - checked the jar was built by JDK 8 version 52.0 (Java 1.8) Best, Leonard > 2025 4月 29 19:55,Yanquan Lv 写道: > > H

Re: [DISCUSS] FLIP-525: Model ML_PREDICT, ML_EVALUATE Implementation Design

2025-05-06 Thread Ron Liu
Hi, Hao Thanks for starting this proposal, it's a great feature, +1. Since I was missing some context, I went to FLIP-437. Combining these two FLIPs, I have the following three questions: 1. Why is it necessary to define the task option in the WITH clause of the Model DDL, and what is its purpose

Re:Re: [DISCUSS] FLIP-486: Introduce a new DeltaJoin

2025-05-06 Thread Xuyang
Hi, Weijie. Thanks for your review! Let me try to answer these questions. 1. The nodes between source and join must be included in the whitelist, such as Calc, DropUpdateBefore, WatermarkAssigner, Exchange and etc. You can see more in chapter "Limitations about Delta Join with Eventual Cons

Re: [DISCUSS] FLIP-525: Model ML_PREDICT, ML_EVALUATE Implementation Design

2025-05-06 Thread Yunfeng Zhou
Hi Hao, Thanks for the FLIP! It provides a clearer guideline for developers to implement model functions. One minor comment: it might be better to change the configuration api_key to apikey, which corresponds to GlobalConfiguration.SENSITIVE_KEYS. Otherwise users’ secrets might be exposed in l

Re:[VOTE] Apache Flink CDC Release 3.4.0, release candidate #3

2025-05-06 Thread 欧阳武林
Tks kunni, +1 At 2025-04-29 19:55:31, "Yanquan Lv" wrote: >Hi everyone, >Please review and vote on the release candidate #3 for the version 3.4.0 of >Apache Flink CDC, >as follows: >[ ] +1, Approve the release >[ ] -1, Do not approve the release (please provide specific comments)

Re: [DISCUSS] FLIP-434: Support optimizations for pre-partitioned data sources

2025-05-06 Thread Lu Niu
Hi, Flink devs This proposal makes sense and we need this in our user case. What's the latest update on this? Additionally, we are interested in understanding how we could utilize this to implement a storage partition join, similar to https://issues.apache.org/jira/browse/SPARK-37375. It seems th

[jira] [Created] (FLINK-37764) Add support for configurable custom TrustManagerFactory in SSLUtils

2025-05-06 Thread Purshotam Shah (Jira)
Purshotam Shah created FLINK-37764: -- Summary: Add support for configurable custom TrustManagerFactory in SSLUtils Key: FLINK-37764 URL: https://issues.apache.org/jira/browse/FLINK-37764 Project: Flin

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

2025-05-06 Thread Mayank Juneja
Hi Ferenc, Thanks for your question! We agree that a CONNECTION could logically be a catalog-level resource, especially since it’s intended to be reused across multiple tables. However, we think there’s value in defining it at the database level to introduce a layer of isolation and scoping. This

Re: [VOTE] FLIP-520: Simplify StructuredType handling

2025-05-06 Thread Hao Li
+1 (non-binding) Thanks for driving this! Hao On Tue, May 6, 2025 at 8:27 AM Ferenc Csaky wrote: > +1 (binding) > > Thanks for driving this! > > Best, > Ferenc > > > > > On Tuesday, May 6th, 2025 at 14:50, Sergey Nuyanzin > wrote: > > > > > > > Thank you for driving this > > +1 (binding) > >

Re: [VOTE] FLIP-520: Simplify StructuredType handling

2025-05-06 Thread Ferenc Csaky
+1 (binding) Thanks for driving this! Best, Ferenc On Tuesday, May 6th, 2025 at 14:50, Sergey Nuyanzin wrote: > > > Thank you for driving this > +1 (binding) > > On Tue, May 6, 2025, 12:04 Timo Walther twal...@apache.org wrote: > > > Hi everyone, > > > > I'd like to start a vote on FLI

Re: [DISCUSS] FLIP-516: Multi-Way Join Operator

2025-05-06 Thread Ferenc Csaky
Hi, I think the FLIP is in a fairly good state, +1 for the idea and the given design. This may be considered already, but IMO we should also add some high-level details, pros, and cons of enabling this feature to the website other than the config option description. Best, Ferenc On Friday, Ma

[jira] [Created] (FLINK-37763) Support multiple tables with set semantics

2025-05-06 Thread Timo Walther (Jira)
Timo Walther created FLINK-37763: Summary: Support multiple tables with set semantics Key: FLINK-37763 URL: https://issues.apache.org/jira/browse/FLINK-37763 Project: Flink Issue Type: Sub-ta

[jira] [Created] (FLINK-37762) No Infomation

2025-05-06 Thread 911432 (Jira)
911432 created FLINK-37762: -- Summary: No Infomation Key: FLINK-37762 URL: https://issues.apache.org/jira/browse/FLINK-37762 Project: Flink Issue Type: Improvement Components: Flink CDC

Re: [VOTE] FLIP-520: Simplify StructuredType handling

2025-05-06 Thread Sergey Nuyanzin
Thank you for driving this +1 (binding) On Tue, May 6, 2025, 12:04 Timo Walther wrote: > Hi everyone, > > I'd like to start a vote on FLIP-520: Simplify StructuredType handling > [1] which has been discussed in this thread [2]. > > The vote will be open for at least 72 hours unless there is an o

Re: [VOTE] FLIP-520: Simplify StructuredType handling

2025-05-06 Thread Ramin Gharib
+1 (non-binding) Thanks for driving this! Best, Ramin On Tue, May 6, 2025 at 12:04 PM Timo Walther wrote: > Hi everyone, > > I'd like to start a vote on FLIP-520: Simplify StructuredType handling > [1] which has been discussed in this thread [2]. > > The vote will be open for at least 72 hour

[jira] [Created] (FLINK-37761) BatchJobRecoveryTest.testJobVertexUnFinishedAndOperatorCoordinatorNotSupportBatchSnapshot test failed of test_cron_azure core pipeline

2025-05-06 Thread dalongliu (Jira)
dalongliu created FLINK-37761: - Summary: BatchJobRecoveryTest.testJobVertexUnFinishedAndOperatorCoordinatorNotSupportBatchSnapshot test failed of test_cron_azure core pipeline Key: FLINK-37761 URL: https://issues.ap

Re: [DISCUSS] FLIP-519: Introduce async lookup key ordered mode

2025-05-06 Thread shuai xu
Hi, devs, There haven’t been any further responses to this email over the past few days. I'd like to initiate a vote on the current proposal[1] in the next few days. If there are any concerns about this FLIP-519[1], I will gladly pause and make necessary adjustments. Best, Xu Shuai [1]htt

[VOTE] FLIP-520: Simplify StructuredType handling

2025-05-06 Thread Timo Walther
Hi everyone, I'd like to start a vote on FLIP-520: Simplify StructuredType handling [1] which has been discussed in this thread [2]. The vote will be open for at least 72 hours unless there is an objection or not enough votes. [1] https://cwiki.apache.org/confluence/display/FLINK/FLIP-520%

Re: [DISCUSS] FLIP-527 Support EXPLAIN EXECUTE STATEMENT SET Syntax in Flink SQL

2025-05-06 Thread Ramin Gharib
Hi Flink Community, Following the discussion on FLIP-528: Support EXPLAIN EXECUTE STATEMENT SET Syntax in Flink SQL, the proposal has been thoroughly discussed, and the main points have been addressed. So, I'll be starting the voting process tomorrow. Please review the final version of the FLIP

[KINDLY REMINDER] Flink 2.1 Release Sync 07/05/2025

2025-05-06 Thread Ron Liu
Hi, everyone! The next release sync will be held at the following time. - 14:00, May 7, BJT (GMT+8) - 08:00, May 7, CET (GMT+2) - 23:00, May 6, PT (GMT-7) Everyone is welcome to join via Google Meet [1]. The topics to be discussed can be found at the Status / Follow-ups section of the release wik

[jira] [Created] (FLINK-37760) Bump parquet version to 1.15.2

2025-05-06 Thread Jira
Márton Balassi created FLINK-37760: -- Summary: Bump parquet version to 1.15.2 Key: FLINK-37760 URL: https://issues.apache.org/jira/browse/FLINK-37760 Project: Flink Issue Type: Bug