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

2024-11-05 Thread Xia Sun
Congratulations Junrui! Best, Xia Zakelly Lan 于2024年11月6日周三 09:57写道: > Congratulations, Junrui! > > > Best, > Zakelly > > On Wed, Nov 6, 2024 at 9:50 AM Feng Jin wrote: > > > Congratulations Junrui! > > > > > > Best, > > Feng > > > > > > On Wed, Nov 6, 2024 at 9:36 AM Rui Fan <1996fan...@gmai

[RESULT][VOTE] FLIP-470: Support Adaptive Broadcast Join

2024-08-14 Thread Xia Sun
Hi everyone, I'm delighted to announce that FLIP-470 [1] has been accepted and voted through this thread [2]. There were 3 votes in favor: - Lincoln Lee (binding) - Zhu Zhu (binding) - Ron Liu (binding) Thanks to all involved. [1] https://cwiki.apache.org/confluence/display/FLINK/FLIP-470%3A+Su

[VOTE] FLIP-470: Support Adaptive Broadcast Join

2024-08-11 Thread Xia Sun
Hi everyone, Thanks for all the feedback about FLIP-470: Support Adaptive Broadcast Join[1]. The discussion thread can be found here[2]. The vote will be open for at least 72 hours unless there are any objections or insufficient votes. Best Xia [1] https://cwiki.apache.org/confluence/display/FL

Re: [DISCUSS] FLIP-470: Support Adaptive Broadcast Join

2024-08-04 Thread Xia Sun
Hi all, Thanks for all the feedback and suggestions so far. If there are no further comments, we will open the voting thread tomorrow, Aug 6, 2024. Best, Xia Lincoln Lee 于2024年8月1日周四 22:18写道: > Hi Xia, > > Thanks for your updates! Looks good to me. > > Best, > Lincoln Lee &g

Re: [DISCUSS] FLIP-470: Support Adaptive Broadcast Join

2024-07-31 Thread Xia Sun
mited to broadcast join > scenarios and will not continuously bring more new options, WDYT? > > > Best, > Lincoln Lee > > > Xia Sun 于2024年7月30日周二 11:27写道: > > > Hi Lincoln, > > > > Thank you for your input and participation in the

Re: [DISCUSS] FLIP-470: Support Adaptive Broadcast Join

2024-07-29 Thread Xia Sun
iu 于2024年7月26日周五 11:59写道: > > > Hi, Xia > > > > Thanks for your reply. It looks good to me. > > > > > > Best, > > Ron > > > > Xia Sun 于2024年7月26日周五 10:49写道: > > > > > Hi Ron, > > > > > > Thanks for your feedb

Re: [DISCUSS] FLIP-470: Support Adaptive Broadcast Join

2024-07-25 Thread Xia Sun
t; > It's a good start to adaptively optimize the logical execution plan with > > runtime information. > > > > Thanks, > > Zhu > > > > Xia Sun 于2024年7月18日周四 18:23写道: > > > > > Hi devs, > > > > > > Junrui Lee, Lei Yang, a

[DISCUSS] FLIP-470: Support Adaptive Broadcast Join

2024-07-18 Thread Xia Sun
refer to FLIP-470[1]. We look forward to your feedback. Best, Junrui Lee, Lei Yang and Xia Sun [1] https://cwiki.apache.org/confluence/display/FLINK/FLIP-470%3A+Support+Adaptive+Broadcast+Join [2] https://cwiki.apache.org/confluence/display/FLINK/FLIP-468%3A+Introducing+StreamGraph-Based+Job

Re: [ANNOUNCE] New Apache Flink PMC Member - Fan Rui

2024-06-06 Thread Xia Sun
Congratulations, Rui! Best, Xia Paul Lam 于2024年6月6日周四 11:59写道: > Congrats, Rui! > > Best, > Paul Lam > > > 2024年6月6日 11:02,Junrui Lee 写道: > > > > Congratulations, Rui. > > > > Best, > > Junrui > > > > Hang Ruan 于2024年6月6日周四 10:35写道: > > > >> Congratulations, Rui! > >> > >> Best, > >> Hang > >

[RESULT][VOTE] FLIP-445: Support dynamic parallelism inference for HiveSource

2024-05-05 Thread Xia Sun
Hi all, FLIP-445: Support dynamic parallelism inference for HiveSource[1] has been accepted and voted through this thread [2]. The proposal has been accepted with 6 approving votes (5 binding) and there is no disapproval: - Muhammet Orazov (non-binding) - Rui Fan (binding) - Ron Liu (binding) -

[VOTE] FLIP-445: Support dynamic parallelism inference for HiveSource

2024-04-25 Thread Xia Sun
Hi everyone, I'd like to start a vote on FLIP-445: Support dynamic parallelism inference for HiveSource[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. [1] https://cwiki.apache.org/confluence/display/F

Re: [DISCUSS] FLIP-445: Support dynamic parallelism inference for HiveSource

2024-04-25 Thread Xia Sun
ats/sources > like Iceberg, Hudi and Delta lake? > > Thanks > Venkat > > On Wed, Apr 24, 2024, 7:41 PM Xia Sun wrote: > > > Hi everyone, > > > > Thanks for all the feedback! > > > > If there are no more comments, I would like to start the vote thread,

Re: [DISCUSS] FLIP-445: Support dynamic parallelism inference for HiveSource

2024-04-24 Thread Xia Sun
; +1 for the proposal. > Best Regards > Ahmed Hamdy > > > On Thu, 18 Apr 2024 at 12:21, Ron Liu wrote: > > > Hi, Xia > > > > Thanks for updating, looks good to me. > > > > Best, > > Ron > > > > Xia Sun 于2024年4月18日周四 19:11写道: > &g

Re: [DISCUSS] FLIP-445: Support dynamic parallelism inference for HiveSource

2024-04-18 Thread Xia Sun
ould list the various behaviors of these two options that > coexist in FLIP by a table, only then users can know how the dynamic and > static parallelism inference work. > > Best, > Ron > > Xia Sun 于2024年4月18日周四 16:33写道: > > > Hi Ron and Lijie, > > Thanks for jo

Re: [DISCUSS] FLIP-445: Support dynamic parallelism inference for HiveSource

2024-04-18 Thread Xia Sun
elism.mode` compatible? > > 4. In FLIP-367 it is supported to be able to set the Source's parallelism > > individually, if in the future HiveSource also supports this feature, > > however, the default value of > > `table.exec.hive.infer-source-parallelism.mode` is `InferMo

Re: [DISCUSS] FLIP-445: Support dynamic parallelism inference for HiveSource

2024-04-16 Thread Xia Sun
ce-parallelism` > and no additional `table.exec.hive.infer-source-parallelism.enabled` > option is required. > > What do you think? > > Best, > Muhammet > > On 2024-04-16 07:07, Xia Sun wrote: > > Hi everyone, > > I would like to start a discussion on FLIP-445: Su

[DISCUSS] FLIP-445: Support dynamic parallelism inference for HiveSource

2024-04-16 Thread Xia Sun
Hi everyone, I would like to start a discussion on FLIP-445: Support dynamic parallelism inference for HiveSource[1]. FLIP-379[2] has introduced dynamic source parallelism inference for batch jobs, which can utilize runtime information to more accurately decide the source parallelism. As a follow-

Re: [ANNOUNCE] New Apache Flink Committer - Zakelly Lan

2024-04-15 Thread Xia Sun
Congratulations Zakelly! Best, Xia Leonard Xu 于2024年4月15日周一 16:16写道: > Congratulations Zakelly! > > > Best, > Leonard > > 2024年4月15日 下午3:56,Samrat Deb 写道: > > > > Congratulations Zakelly! > >

Re: Question around Flink's AdaptiveBatchScheduler

2024-04-15 Thread Xia Sun
Hi Venkat, I agree that the parallelism of source vertex should not be upper bounded by the job's global max parallelism. The case you mentioned, >> High filter selectivity with huge amounts of data to read excellently supports this viewpoint. (In fact, in the current implementation, if the source

Re: [ANNOUNCE] New Apache Flink PMC Member - Jing Ge

2024-04-14 Thread Xia Sun
Congratulations, Jing! Best, Xia Ferenc Csaky 于2024年4月13日周六 00:50写道: > Congratulations, Jing! > > Best, > Ferenc > > > > On Friday, April 12th, 2024 at 13:54, Ron liu wrote: > > > > > > > Congratulations, Jing! > > > > Best, > > Ron > > > > Junrui Lee jrlee@gmail.com 于2024年4月12日周五 18:54写道:

Re: [ANNOUNCE] New Apache Flink PMC Member - Lincoln Lee

2024-04-14 Thread Xia Sun
Congratulations Lincoln ! Best, Xia Ferenc Csaky 于2024年4月13日周六 00:50写道: > Congratulations, Lincoln! > > Best, > Ferenc > > > > > On Friday, April 12th, 2024 at 15:54, lorenzo.affe...@ververica.com.INVALID > wrote: > > > > > > > Huge congrats! Well done! > > On Apr 12, 2024 at 13:56 +0200, Ron

[RESULT][VOTE] FLIP-379: Dynamic source parallelism inference for batch jobs

2023-12-05 Thread Xia Sun
Dear developers, FLIP-379: Dynamic source parallelism inference for batch jobs[1] has been accepted and voted through this thread [2]. The proposal received 6 approving binding votes and there is no disapproval: - Zhu Zhu (binding) - Lijie Wang (binding) - Rui Fan (binding) - Etienne Chauchot (b

[VOTE] FLIP-379: Dynamic source parallelism inference for batch jobs

2023-11-29 Thread Xia Sun
Hi everyone, I'd like to start a vote on FLIP-379: Dynamic source parallelism inference for batch jobs[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. [1] https://cwiki.apache.org/confluence/display/FL

Re: [DISCUSS] FLIP-379: Dynamic source parallelism inference for batch jobs

2023-11-28 Thread Xia Sun
gt; job, the updated FLIP looks good to me. > > Best, > Leonard > > > > 2023年11月24日 下午5:53,Xia Sun 写道: > > > > Hi all, > > Offline discussed with Zhu Zhu and Leonard Xu and we have reached the > > following three points of consensus: > > > > 1.

Re: [DISCUSS] FLIP-379: Dynamic source parallelism inference for batch jobs

2023-11-24 Thread Xia Sun
anks Xia and Zhu Zhu for kickoff this discussion. > >>>> > >>>> The dynamic source parallelism inference is a useful feature for batch > >>>> story. I’ve some comments about current design. > >>>> > >>>> 1.How user disable

Re: [DISCUSS] FLIP-379: Dynamic source parallelism inference for batch jobs

2023-11-20 Thread Xia Sun
not > >> resolve all case, because other Sources can set their own parallelism > too. > >> > >> 3.Current design only works for batch josb, the workflow for streaming > job > >> may looks like (1) inference parallelism for streaming source like > kafka

Re: [VOTE] FLIP-381: Deprecate configuration getters/setters that return/set complex Java objects

2023-11-12 Thread Xia Sun
+1 (non-binding) Best, Xia Samrat Deb 于2023年11月13日周一 12:37写道: > +1 (non binding) > > Bests, > Samrat > > On Mon, 13 Nov 2023 at 9:10 AM, Yangze Guo wrote: > > > +1 (binding) > > > > Best, > > Yangze Guo > > > > On Mon, Nov 13, 2023 at 11:35 AM weijie guo > > wrote: > > > > > > +1(binding) > >

Re: [DISCUSS] FLIP-379: Dynamic source parallelism inference for batch jobs

2023-11-09 Thread Xia Sun
reaming Hive > Source should not apply the dynamic source parallelism even it implemented > the feature as it severing a streaming job. > > Best, > Leonard > > > > 2023年11月1日 下午6:21,Xia Sun 写道: > > > > Thanks Lijie for the comments! > > 1. For Hive s

Re: [DISCUSS] FLIP-379: Dynamic source parallelism inference for batch jobs

2023-11-01 Thread Xia Sun
ve batch scheduler. > > > > Besides that, it is also one good step towards supporting dynamic > > parallelism inference for streaming sources, e.g. allowing Kafka > > sources to determine its parallelism automatically based on the > > number of partitions. > >

[DISCUSS] FLIP-379: Dynamic source parallelism inference for batch jobs

2023-10-31 Thread Xia Sun
Hi everyone, I would like to start a discussion on FLIP-379: Dynamic source parallelism inference for batch jobs[1]. In general, there are three main ways to set source parallelism for batch jobs: (1) User-defined source parallelism. (2) Connector static parallelism inference. (3) Dynamic parallel

Re: [VOTE] FLIP-324: Introduce Runtime Filter for Flink Batch Jobs

2023-06-24 Thread Xia Sun
+1 (non-binding) Best Regards, Xia yuxia 于2023年6月25日周日 09:23写道: > +1 (binding) > Thanks Lijie driving it. > > Best regards, > Yuxia > > - 原始邮件 - > 发件人: "Yuepeng Pan" > 收件人: "dev" > 发送时间: 星期六, 2023年 6 月 24日 下午 9:06:53 > 主题: Re:[VOTE] FLIP-324: Introduce Runtime Filter for Flink Batch

Re: [DISCUSS] FLIP-301: Hybrid Shuffle supports Remote Storage

2023-03-12 Thread Xia Sun
Hi Yuxin, Thanks for creating this FLIP! I'm a flink user, and in our internal scenario we use the colocation technology to run flink jobs and online service on the same machine together. We found that flink jobs are occasionally affected by other non-flink jobs (i.e. if the host disk space is ful