[jira] [Created] (FLINK-34993) Support Model CRUD in parser

2024-04-02 Thread Hao Li (Jira)
Hao Li created FLINK-34993: -- Summary: Support Model CRUD in parser Key: FLINK-34993 URL: https://issues.apache.org/jira/browse/FLINK-34993 Project: Flink Issue Type: Sub-task Reporter:

[jira] [Created] (FLINK-34992) FLIP-437: Support ML Models in Flink SQL

2024-04-02 Thread Hao Li (Jira)
Hao Li created FLINK-34992: -- Summary: FLIP-437: Support ML Models in Flink SQL Key: FLINK-34992 URL: https://issues.apache.org/jira/browse/FLINK-34992 Project: Flink Issue Type: New Feature

Re: [DISCUSS] FLIP-435: Introduce a New Dynamic Table for Simplifying Data Pipelines

2024-04-02 Thread Ron liu
Hi, dev After offline discussion with Becket Qin, Lincoln Lee and Jark Wu, we have improved some parts of the FLIP. 1. Add Full Refresh Mode section to clarify the semantics of full refresh mode. 2. Add Future Improvement section explaining why query statement does not support references to

Re: [VOTE] FLIP-437: Support ML Models in Flink SQL

2024-04-02 Thread Yu Chen
+1 (non-binding) Looking forward to this future. Thanks, Yu Chen > 2024年4月3日 10:23,Jark Wu 写道: > > +1 (binding) > > Best, > Jark > > On Tue, 2 Apr 2024 at 15:12, Timo Walther wrote: > >> +1 (binding) >> >> Thanks, >> Timo >> >> On 29.03.24 17:30, Hao Li wrote: >>> Hi devs, >>> >>> I'd

Re: [VOTE] FLIP-437: Support ML Models in Flink SQL

2024-04-02 Thread Jark Wu
+1 (binding) Best, Jark On Tue, 2 Apr 2024 at 15:12, Timo Walther wrote: > +1 (binding) > > Thanks, > Timo > > On 29.03.24 17:30, Hao Li wrote: > > Hi devs, > > > > I'd like to start a vote on the FLIP-437: Support ML Models in Flink > > SQL [1]. The discussion thread is here [2]. > > > > The

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

2024-04-02 Thread Jeyhun Karimov
Hi Lincoln, Thanks a lot for your comments. Please find my answers below. 1. Is this flip targeted only at batch scenarios or does it include > streaming? > (The flip and the discussion did not explicitly mention this, but in the > draft pr, I only > saw the implementation for batch scenarios >

Re: [DISCUSS] FLIP-XXX Apicurio-avro format

2024-04-02 Thread Balint Bene
+1 to this as well, as we were talking about this on the other generic thread about supporting headers at the serdes layer. Couple of tiny points: > passHeadersToSerDe option If the interface can be made backwards compatible, is there a need for this option anymore? For example adding default

[jira] [Created] (FLINK-34991) Flink Operator ClassPath Race Condition Bug

2024-04-02 Thread Ryan van Huuksloot (Jira)
Ryan van Huuksloot created FLINK-34991: -- Summary: Flink Operator ClassPath Race Condition Bug Key: FLINK-34991 URL: https://issues.apache.org/jira/browse/FLINK-34991 Project: Flink

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

2024-04-02 Thread Lincoln Lee
Hi Jeyhun, Thank you for driving this, it would be very useful optimization! Sorry for joining the discussion now(I originally planned to reply earlier, but happened to be during my vacation). I have two questions: 1. Is this flip targeted only at batch scenarios or does it include streaming?

[jira] [Created] (FLINK-34990) [feature][cdc-connector][oracle] Oracle cdc support newly add table

2024-04-02 Thread Xin Gong (Jira)
Xin Gong created FLINK-34990: Summary: [feature][cdc-connector][oracle] Oracle cdc support newly add table Key: FLINK-34990 URL: https://issues.apache.org/jira/browse/FLINK-34990 Project: Flink

[jira] [Created] (FLINK-34989) Apache Infra requests to reduce the runner usage for a project

2024-04-02 Thread Matthias Pohl (Jira)
Matthias Pohl created FLINK-34989: - Summary: Apache Infra requests to reduce the runner usage for a project Key: FLINK-34989 URL: https://issues.apache.org/jira/browse/FLINK-34989 Project: Flink

[jira] [Created] (FLINK-34988) Class loading issues in JDK17 and JDK21

2024-04-02 Thread Matthias Pohl (Jira)
Matthias Pohl created FLINK-34988: - Summary: Class loading issues in JDK17 and JDK21 Key: FLINK-34988 URL: https://issues.apache.org/jira/browse/FLINK-34988 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-34987) Introduce Internal State Interface for Async API

2024-04-02 Thread Hangxiang Yu (Jira)
Hangxiang Yu created FLINK-34987: Summary: Introduce Internal State Interface for Async API Key: FLINK-34987 URL: https://issues.apache.org/jira/browse/FLINK-34987 Project: Flink Issue Type:

Re: [VOTE] FLIP-437: Support ML Models in Flink SQL

2024-04-02 Thread Timo Walther
+1 (binding) Thanks, Timo On 29.03.24 17:30, Hao Li wrote: Hi devs, I'd like to start a vote on the FLIP-437: Support ML Models in Flink SQL [1]. The discussion thread is here [2]. The vote will be open for at least 72 hours unless there is an objection or insufficient votes. [1]

Re: Re: Iceberg table maintenance

2024-04-02 Thread Péter Váry
Thanks Wenjin for your response. See my answers below: On Tue, Apr 2, 2024, 04:08 wenjin wrote: > Hi Peter, > Thanks a lot for your answers, this detailed explanation has cleared my > confusions and been greatly beneficial to me. If you don't mind, could I > discuss two more questions with