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

2025-05-05 Thread Piotr Nowojski
Hi, sounds like an interesting feature! Best, Piotrek wt., 29 kwi 2025 o 03:52 Shengkai Fang napisał(a): > Hi, Hao. > > Thanks for your proposal about ML related functions. This FLIP will help > others to implement their own model provider. > > +1 for the proposal. > > Best, > Shengkai > > Hao

[RESULT][VOTE] FLIP-524: CloudWatch Metric Sink Connector

2025-05-05 Thread Daren Wong
Hi devs, The vote[1] on FLIP-524[2] concluded with the following results: Approving(+1) votes: Robert Metzger (binding) Priya Dhingra (non-binding) Ferenc Csaky (binding) Danny Cranmer (binding) Hong Liang Teoh (binding) There were no disproving(-1) votes. I'm happy to announce that F

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

2025-05-05 Thread Hao Li
Hi Yash, ML_EVALUATE itself will be an `TableAggregateFunction`. We will only provide one implementation in Flink which will be used in codegen. Only ML_PREDICT function implementation can be based on providers. Flink will also provide a default implementation for it. Thanks, Hao On Mon, May 5,

Re: [DISCUSS] FLIP-521: Integrating Variant Type into Flink: Enabling Efficient Semi-Structured Data Processing

2025-05-05 Thread Timo Walther
Hi Xuannan, thank you for updating the FLIP and addressing my comments. The FLIP is in a very good shape now, +1 for voting. I just found some last remaining items that would be good to be addressed in the FLIP. But not blocker for the voting process: > isScalar() I thought about the naming

Re: [VOTE] FLIP-518: Introduce a community review process

2025-05-05 Thread Robert Metzger
+1 (binding) Thanks for driving this! On Sun, May 4, 2025 at 5:18 PM Yuepeng Pan wrote: > +1 (non-binding) > > Thanks for driving it! > > Best regards, > Yuepeng. > > On 2025/05/03 00:15:04 Hong Liang wrote: > > +1 (binding) > > > > Thanks for driving this! It is a great way to engage the comm

Re: [DISCUSS] FLIP-526: Model ML_PREDICT, ML_EVALUATE Table API

2025-05-05 Thread Piotr Nowojski
Hi, sounds like a valuable addition! Best, Piotrek wt., 29 kwi 2025 o 03:57 Shengkai Fang napisał(a): > Hi, Hao. > > +1 for the proposal. > > Best, > Shengkai > > Hao Li 于2025年4月29日周二 07:27写道: > > > Hi All, > > > > I would like to start a discussion about FLIP-526 [1]: Model ML_PREDICT, > > M

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

2025-05-05 Thread Yash Anand
Hi Hao, Thanks for the proposal, these are really interesting features to extend Flink ML use case. +1 for the proposal. I just have one question, since you plan to extend SqlMlFunctionTableFunction for both ML functions builtin registrations, will ML_EVALUATE be an aggregate function or Table f

Re: [DISCUSS] FLIP-526: Model ML_PREDICT, ML_EVALUATE Table API

2025-05-05 Thread Yash Anand
Hi, Hao. +1 for the proposal. Thanks Yas On Mon, May 5, 2025 at 4:17 AM Piotr Nowojski wrote: > Hi, > > sounds like a valuable addition! > > Best, > Piotrek > > wt., 29 kwi 2025 o 03:57 Shengkai Fang napisał(a): > > > Hi, Hao. > > > > +1 for the proposal. > > > > Best, > > Shengkai > > > > Ha

[jira] [Created] (FLINK-37754) Optimizing OLAP query speed in session cluster.

2025-05-05 Thread Weijun Wang (Jira)
Weijun Wang created FLINK-37754: --- Summary: Optimizing OLAP query speed in session cluster. Key: FLINK-37754 URL: https://issues.apache.org/jira/browse/FLINK-37754 Project: Flink Issue Type: New

[jira] [Created] (FLINK-37756) Add a new byte array method for submitting jobGraph.

2025-05-05 Thread Weijun Wang (Jira)
Weijun Wang created FLINK-37756: --- Summary: Add a new byte array method for submitting jobGraph. Key: FLINK-37756 URL: https://issues.apache.org/jira/browse/FLINK-37756 Project: Flink Issue Type

[jira] [Created] (FLINK-37755) Make retryMillis in CollectResultFetcher configurable.

2025-05-05 Thread Weijun Wang (Jira)
Weijun Wang created FLINK-37755: --- Summary: Make retryMillis in CollectResultFetcher configurable. Key: FLINK-37755 URL: https://issues.apache.org/jira/browse/FLINK-37755 Project: Flink Issue Ty

[jira] [Created] (FLINK-37758) Support skip some checkpoint operators in JobManager.

2025-05-05 Thread Weijun Wang (Jira)
Weijun Wang created FLINK-37758: --- Summary: Support skip some checkpoint operators in JobManager. Key: FLINK-37758 URL: https://issues.apache.org/jira/browse/FLINK-37758 Project: Flink Issue Typ

[jira] [Created] (FLINK-37757) Add StandaloneJobGraphStore and EmbeddedJobResultStore to skip some IO.

2025-05-05 Thread Weijun Wang (Jira)
Weijun Wang created FLINK-37757: --- Summary: Add StandaloneJobGraphStore and EmbeddedJobResultStore to skip some IO. Key: FLINK-37757 URL: https://issues.apache.org/jira/browse/FLINK-37757 Project: Flink

[jira] [Created] (FLINK-37759) Support avoid repeatedly downloading user jars in session mode.

2025-05-05 Thread Weijun Wang (Jira)
Weijun Wang created FLINK-37759: --- Summary: Support avoid repeatedly downloading user jars in session mode. Key: FLINK-37759 URL: https://issues.apache.org/jira/browse/FLINK-37759 Project: Flink

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

2025-05-05 Thread Timo Walther
Hi everyone, if there are no objections, I would start a voting thread by tomorrow. Thanks, Timo On 29.04.25 11:46, Timo Walther wrote: Hi Hao, thanks for your feedback. Currently, the Python API does not support structured types at all. So this might require another FLIP in the future with