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

2025-05-07 Thread Ron Liu
Hi, Xuyang Thanks for initiating this FLIP, which is of great value in solving the Streaming Join that troubles many users. Big +1 for it. For the overall design of FLIP, I have the following questions: 1. Can you explain the currently supported Join types in FLIP, such as Inner, Left, and Right

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

2025-05-07 Thread Jingsong Li
+1 binding On Thu, May 8, 2025 at 11:17 AM Leonard Xu wrote: > > +1(binding) > > Best, > Leonard > > > 2025 5月 8 09:58,Ron Liu 写道: > > > > +1(binding) > > > > Best, > > Ron > > > > weijie guo 于2025年5月7日周三 21:15写道: > > > >> +1(binding) > >> > >> Best regards, > >> > >> Weijie > >> > >> > >> Xint

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

2025-05-07 Thread Leonard Xu
+1(binding) Best, Leonard > 2025 5月 8 09:58,Ron Liu 写道: > > +1(binding) > > Best, > Ron > > weijie guo 于2025年5月7日周三 21:15写道: > >> +1(binding) >> >> Best regards, >> >> Weijie >> >> >> Xintong Song 于2025年5月7日周三 19:37写道: >> >>> +1 (binding) >>> >>> Best, >>> >>> Xintong >>> >>> >>>

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

2025-05-07 Thread Ron Liu
Hi, Gustavo Sorry for the late participation in the FLIP discussion, this is a great feature to solve the headache of the stream join, Big +1. Regarding the new config option `table.optimizer.multi-join.enabled`, I have a question: is this option only effective in streaming mode, what is its beha

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

2025-05-07 Thread Ron Liu
+1(binding) Best, Ron weijie guo 于2025年5月7日周三 21:15写道: > +1(binding) > > Best regards, > > Weijie > > > Xintong Song 于2025年5月7日周三 19:37写道: > > > +1 (binding) > > > > Best, > > > > Xintong > > > > > > > > On Wed, May 7, 2025 at 7:00 PM Lincoln Lee > wrote: > > > > > +1 (binding) > > > > > > >

[VOTE] FLIP-516: Multi-Way Join Operator

2025-05-07 Thread Gustavo de Morais
Hi everyone, I'd like to start voting on FLIP-516: Multi-Way Join Operator [1]. The discussion can be found in this thread [2]. The vote will be open for at least 72 hours, unless there is an objection or not enough votes. Thanks, Gustavo de Morais [1] https://cwiki.apache.org/confluence/displa

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

2025-05-07 Thread Gustavo de Morais
Hey Ferenc, that's a great callout. I'll make sure we add some documentation regarding general advice on when to use multi-way joins (pros and cons). Am Di., 6. Mai 2025 um 17:23 Uhr schrieb Ferenc Csaky : > Hi, > > I think the FLIP is in a fairly good state, +1 for the idea and the given > desig

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

2025-05-07 Thread Hao Li
Hi Ron, I found these names in other systems: `task_type` in big query ML [1] `model_type` in databricks [2] `task` is more of an abbreviated version from `task_type`. [1] https://cloud.google.com/bigquery/docs/reference/standard-sql/bigqueryml-syntax-evaluate [2] https://www.databricks.com/blo

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

2025-05-07 Thread Gustavo de Morais
+1 (non-binding) Thanks Timo, Gustavo Am Mi., 7. Mai 2025 um 04:58 Uhr schrieb 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: > > > > > +

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

2025-05-07 Thread weijie guo
+1(binding) Best regards, Weijie Xintong Song 于2025年5月7日周三 19:37写道: > +1 (binding) > > Best, > > Xintong > > > > On Wed, May 7, 2025 at 7:00 PM Lincoln Lee wrote: > > > +1 (binding) > > > > > > Best, > > Lincoln Lee > > > > > > Gyula Fóra 于2025年5月7日周三 18:43写道: > > > > > +1 (binding) > > > >

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

2025-05-07 Thread Xintong Song
+1 (binding) Best, Xintong On Wed, May 7, 2025 at 7:00 PM Lincoln Lee wrote: > +1 (binding) > > > Best, > Lincoln Lee > > > Gyula Fóra 于2025年5月7日周三 18:43写道: > > > +1 (binding) > > > > Gyula > > > > On Wed, May 7, 2025 at 12:40 PM Timo Walther wrote: > > > > > +1 (binding) > > > > > > Thank

申请退订邮件

2025-05-07 Thread 戴雄军
-- name:DaiXiongJun tel:15652685890 mail:qqq...@163.com qq:191945951 Company:北京兰云科技

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

2025-05-07 Thread Lincoln Lee
+1 (binding) Best, Lincoln Lee Gyula Fóra 于2025年5月7日周三 18:43写道: > +1 (binding) > > Gyula > > On Wed, May 7, 2025 at 12:40 PM Timo Walther wrote: > > > +1 (binding) > > > > Thanks for working on this! > > > > Best, > > Timo > > > > On 07.05.25 11:08, Xuannan Su wrote: > > > Hi everyone, > > >

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

2025-05-07 Thread Gyula Fóra
+1 (binding) Gyula On Wed, May 7, 2025 at 12:40 PM Timo Walther wrote: > +1 (binding) > > Thanks for working on this! > > Best, > Timo > > On 07.05.25 11:08, Xuannan Su wrote: > > Hi everyone, > > > > I'd like to start a vote on FLIP-521: Integrating Variant Type into > > Flink: Enabling Effici

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

2025-05-07 Thread Gabor Somogyi
Hi All, I've read through the concerns/proposals related the watch service and here are my conclusions: * Watch service can watch local file systems only: It's fair to say that certificates must be copied to local FS in order to work (init container cp command or something) * Watch service can sen

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

2025-05-07 Thread Timo Walther
+1 (binding) Thanks for working on this! Best, Timo On 07.05.25 11:08, Xuannan Su wrote: Hi everyone, I'd like to start a vote on FLIP-521: Integrating Variant Type into Flink: Enabling Efficient Semi-Structured Data Processing[1], which has been discussed in this thread[2]. The vote will be

[jira] [Created] (FLINK-37769) Include cause in event when Restarting unhealthy job

2025-05-07 Thread Gyula Fora (Jira)
Gyula Fora created FLINK-37769: -- Summary: Include cause in event when Restarting unhealthy job Key: FLINK-37769 URL: https://issues.apache.org/jira/browse/FLINK-37769 Project: Flink Issue Type:

[jira] [Created] (FLINK-37768) ConstraintEnforcer not handling all constraints

2025-05-07 Thread Dawid Wysakowicz (Jira)
Dawid Wysakowicz created FLINK-37768: Summary: ConstraintEnforcer not handling all constraints Key: FLINK-37768 URL: https://issues.apache.org/jira/browse/FLINK-37768 Project: Flink Issue

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

2025-05-07 Thread Xuannan Su
Hi everyone, I'd like to start a vote on FLIP-521: Integrating Variant Type into Flink: Enabling Efficient Semi-Structured Data Processing[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. Best, Xuannan

[jira] [Created] (FLINK-37767) Update ref version for es connector

2025-05-07 Thread Weijie Guo (Jira)
Weijie Guo created FLINK-37767: -- Summary: Update ref version for es connector Key: FLINK-37767 URL: https://issues.apache.org/jira/browse/FLINK-37767 Project: Flink Issue Type: Technical Debt

[SUMMARY] Flink 2.1 Release Sync 05/07/2025

2025-05-07 Thread Ron Liu
Hi, devs, This is the second 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 7 weeks left until the feature freeze time(June 21, 2025), and developers need to pay attention to the feature fre

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

2025-05-07 Thread Xuannan Su
Hi Timo, Thanks for the suggestion! I updated the FLIP to use `isPrimitive()` and `VariantTypeException`. Regarding `JSON()` and `PARSE_JSON()`, we should keep the return type of the `JSON()` method as it is, and use the `PARSE_JSON()` method to convert a JSON string to a variant type. `JSON`, `