Re: Re: [VOTE] FLIP-214: Support Advanced Function DDL

2022-04-21 Thread
Thanks for driving this work @Ron, > > > > > > +1 (binding) > > > > > > Best, > > > Jark > > > > > > On Thu, 21 Apr 2022 at 10:42, Mang Zhang wrote: > > > > > > > +1 > > > > > > > > > &g

[VOTE] FLIP-214: Support Advanced Function DDL

2022-04-20 Thread
Hi, everyone I'd like to start a vote on FLIP-214: Support Advanced Function DDL [1] which has been discussed in [2]. The vote will be open for at least 72 hours unless there is an objection or not enough votes. [1]

Re: Re: [SPAM] Re: Re: Re: Re: Re: 回复:Re:[DISCUSS] FLIP-214 Support Advanced Function DDL

2022-04-19 Thread
DDL > > Thank Ron for updating the FLIP. > > I think the updated FLIP has addressed Martijn's concern. > I don't have other feedback. So +1 for a vote. > > Best, > Jark > > On Fri, 15 Apr 2022 at 16:36, 刘大龙 wrote: > > > Hi, Jingsong > > > >

Re: Re: Re: Discussion about enhancing the partitioned table syntax

2022-04-15 Thread
FLIP. [1] https://cwiki.apache.org/confluence/display/FLINK/FLIP-63%3A+Rework+table+partition+support Best, Ron > -原始邮件- > 发件人: "刘大龙" > 发送时间: 2022-04-15 17:15:36 (星期五) > 收件人: dev@flink.apache.org > 抄送: > 主题: Re: Re: Discussion about enhancing the part

Re: Re: Discussion about enhancing the partitioned table syntax

2022-04-15 Thread
tijnVisser82 > > https://github.com/MartijnVisser > > > > [1] > > https://cwiki.apache.org/confluence/display/FLINK/Flink+Improvement+Proposals > > [2] https://cwiki.apache.org/confluence/display/FLINK/Flink+Bylaws > > > > > > > > On Fri, 15 Apr 2022 at

Re: [SPAM] Re: Re: Re: Re: Re: 回复:Re:[DISCUSS] FLIP-214 Support Advanced Function DDL

2022-04-15 Thread
t; > not focus on one resource provider, but that at least S3 support is > > included in the same Flink release as HDFS support is. > > > > Best regards, > > > > Martijn Visser > > https://twitter.com/MartijnVisser82 > > https://github.com/MartijnVisser >

Re: Re: Re: Re: Re: Re: 回复:Re:[DISCUSS] FLIP-214 Support Advanced Function DDL

2022-04-15 Thread
> Martijn Visser > https://twitter.com/MartijnVisser82 > https://github.com/MartijnVisser > > > On Thu, 14 Apr 2022 at 08:50, 刘大龙 wrote: > > > Hi, everyone > > > > First of all, thanks for the valuable suggestions received about this > > FLIP. Af

Discussion about enhancing the partitioned table syntax

2022-04-15 Thread
Hi, everyone For partitioned table, there are still some related syntaxes that are not supported, which will be very useful for partitioned table. In batch analysis scenarios, such as Hive table, partitioned table is a very common case. Since the current Flink is mainly for streaming

Re: Re: Re: Re: Re: 回复:Re:[DISCUSS] FLIP-214 Support Advanced Function DDL

2022-04-14 Thread
> -原始邮件- > 发件人: "刘大龙" > 发送时间: 2022-04-08 10:09:46 (星期五) > 收件人: dev@flink.apache.org > 抄送: > 主题: Re: Re: Re: Re: 回复:Re:[DISCUSS] FLIP-214 Support Advanced Function DDL > > Hi, Martijn > > Do you have any question about this FLIP? looking forward to yo

Re: Re: Re: Re: 回复:Re:[DISCUSS] FLIP-214 Support Advanced Function DDL

2022-04-07 Thread
Hi, Martijn Do you have any question about this FLIP? looking forward to your more feedback. Best, Ron > -原始邮件- > 发件人: "刘大龙" > 发送时间: 2022-03-29 19:33:58 (星期二) > 收件人: dev@flink.apache.org > 抄送: > 主题: Re: Re: Re: 回复:Re:[DISCUSS] FLIP-214 S

Re: Re: 回复:Re:[DISCUSS] FLIP-214 Support Advanced Function DDL

2022-03-29 Thread
anies who run Flink: those who > > open it up for everyone to use (here the feature would be welcomed) and > > those who need to follow certain minimum standards/have a more closed Flink > > ecosystem). They usually want to validate a JAR upfront before making it > > ava

Re: Re: Re: 回复:Re:[DISCUSS] FLIP-214 Support Advanced Function DDL

2022-03-29 Thread
ards/have a more closed Flink > ecosystem). They usually want to validate a JAR upfront before making it > available, even at the expense of speed, because it gives them more control > over what will be running in their environment. > > Best regards, > > Martijn Visser > https

Re: Re: 回复:Re:[DISCUSS] FLIP-214 Support Advanced Function DDL

2022-03-23 Thread
> >Hi Ron, Thank you so much for this suggestion, this is so good. > > >In our company, when users use custom UDF, it is very inconvenient, and > > the code needs to be packaged into the job jar, > > >and cannot refer to the existing udf jar through the existing udf jar. > >

Re: 回复:Re:[DISCUSS] FLIP-214 Support Advanced Function DDL

2022-03-23 Thread
kaged into the job jar, > and cannot refer to the existing udf jar through the existing udf jar. > Or pass in the jar reference in the startup command. > If we implement this feature, users can focus on their own business > development. > I can also contribute if needed. &g

Re: Re:[DISCUSS] FLIP-214 Support Advanced Function DDL

2022-03-23 Thread
n their own business > development. > I can also contribute if needed. > > > > > > > > > > > > > > > > -- > > Best regards, > Mang Zhang > > > > > > At 2022-03-21 14:57:32, "刘大龙" wrote: > &g

[DISCUSS] FLIP-214 Support Advanced Function DDL

2022-03-21 Thread
Hi, everyone I would like to open a discussion for support advanced Function DDL, this proposal is a continuation of FLIP-79 in which Flink Function DDL is defined. Until now it is partially released as the Flink function DDL with user defined resources is not clearly discussed and

Re: Re: Re: [ANNOUNCE] New Apache Flink Committer - Rui Li

2021-04-22 Thread
Congratulations Rui! Best > -原始邮件- > 发件人: "Benchao Li" > 发送时间: 2021-04-22 14:43:33 (星期四) > 收件人: dev > 抄送: > 主题: Re: Re: [ANNOUNCE] New Apache Flink Committer - Rui Li > > Congratulations Rui! > > Jingsong Li 于2021年4月22日周四 下午2:33写道: > > > Congratulations Rui! > > > > Best, > >

Re: Re: [VOTE] FLIP-145: Support SQL windowing table-valued function (2nd)

2020-11-11 Thread
+1 > -原始邮件- > 发件人: "Timo Walther" > 发送时间: 2020-11-11 18:55:06 (星期三) > 收件人: dev@flink.apache.org > 抄送: > 主题: Re: [VOTE] FLIP-145: Support SQL windowing table-valued function (2nd) > > +1 (binding) > > Thanks, > Timo > > On 11.11.20 07:14, Pengcheng Liu wrote: > > +1 (binding) > > >

Re: Re: [VOTE] FLIP-145: Support SQL windowing table-valued function

2020-10-10 Thread
+1 > -原始邮件- > 发件人: "Jark Wu" > 发送时间: 2020-10-10 18:50:20 (星期六) > 收件人: dev > 抄送: > 主题: Re: [VOTE] FLIP-145: Support SQL windowing table-valued function > > +1 > > On Sat, 10 Oct 2020 at 18:41, Benchao Li wrote: > > > +1 > > > > Jark Wu 于2020年10月10日周六 下午6:06写道: > > > > > Hi all, >

Re: Re: [DISCUSS] Support source/sink parallelism config in Flink sql

2020-09-20 Thread
+1 > -原始邮件- > 发件人: "Benchao Li" > 发送时间: 2020-09-20 16:28:20 (星期日) > 收件人: dev > 抄送: > 主题: Re: [DISCUSS] Support source/sink parallelism config in Flink sql > > Hi admin, > > Thanks for bringing up this discussion. > IMHO, it's a valuable feature. We also added this feature for our

Re: Re: [ANNOUNCE] New Apache Flink Committer - Godfrey He

2020-09-16 Thread
Congratulations! > -原始邮件- > 发件人: "Benchao Li" > 发送时间: 2020-09-16 14:22:25 (星期三) > 收件人: dev > 抄送: "贺小令" > 主题: Re: [ANNOUNCE] New Apache Flink Committer - Godfrey He > > Congratulations! > > Zhu Zhu 于2020年9月16日周三 下午1:36写道: > > > Congratulations! > > > > Thanks, > > Zhu > > > >

Re: Re: [ANNOUNCE] New Apache Flink Committer - Yun Tang

2020-09-15 Thread
etc. > > > > Besides that, Yun is very actively involved in QA and discussions in the > > user and dev mailing lists (more than 300 replies since Jul. 2018). > > > > Please join me in congratulating Yun for becoming a Flink committer! > > > > Cheers, > > Yu > > > -- 刘大龙 浙江大学 控制系 智能系统与控制研究所 工控新楼217 地址:浙江省杭州市浙大路38号浙江大学玉泉校区 Tel:18867547281

Fw: Re: Re: Re: The use of state ttl incremental cleanup strategy in sql deduplication resulting in significant performance degradation

2020-05-06 Thread
-原始邮件- 发件人:"刘大龙" 发送时间:2020-05-06 17:55:25 (星期三) 收件人: "Jark Wu" 抄送: 主题: Re: Re: Re: The use of state ttl incremental cleanup strategy in sql deduplication resulting in significant performance degradation Thanks for your tuning ideas, I will test it later. Just

Re: Re: The use of state ttl incremental cleanup strategy in sql deduplication resulting in significant performance degradation

2020-04-29 Thread
ateVisibility(StateTtlConfig.StateVisibility.NeverReturnExpired) > .build(); > > > Best, > Jark > > > [1]: > https://github.com/apache/flink/blob/master/flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/util/StateTtlConfigUtil.java#L

The use of state ttl incremental cleanup strategy in sql deduplication resulting in significant performance degradation

2020-04-28 Thread
Hi, all! At flink master branch, we have supported state ttl for sql mini-batch deduplication using incremental cleanup strategy on heap backend, refer to FLINK-16581. Because I want to test the performance of this feature, so I compile master branch code and deploy the jar to production