> Thanks for driving this work @Ron,
> > >
> > > +1 (binding)
> > >
> > > Best,
> > > Jark
> > >
> > > On Thu, 21 Apr 2022 at 10:42, Mang Zhang wrote:
> > >
> > > > +1
> > > >
> > > >
&g
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]
https://cwiki.apache.org/confluence/display/FLINK/FLIP-214+Support+Adva
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
> >
a new 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
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 09:
ld
> > 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
>
> 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
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 process
> -原始邮件-
> 发件人: "刘大龙"
> 发送时间: 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
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
gt; think there are roughly two types of companies 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
ollow certain minimum standards/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,
>
-214 Support Advanced Function DDL
> > >
> > >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 ex
s 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.
> Or pass in the jar reference in the startup command.
> If we implement this feature, users can focus on their own business
> deve
n their own business
> development.
> I can also contribute if needed.
>
>
>
>
>
>
>
>
>
>
>
>
>
>
>
> --
>
> Best regards,
> Mang Zhang
>
>
>
>
>
> At 2022-03-21 14:57:32, "刘大龙" wrote:
> &g
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 implement
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,
> > Jings
+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)
> >
> >
+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,
> >
+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 int
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
> >
> > Leonar
nagement, 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
-原始邮件-
发件人:"刘大龙"
发送时间: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
)
> .setStateVisibility(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/StateTtlCo
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 envir
25 matches
Mail list logo