Re: [ANNOUNCE] Zhijiang Wang has been added as a committer to the Flink project

2019-07-22 Thread Bo WANG
Congratulations Zhijiang! Best, Bo WANG On Mon, Jul 22, 2019 at 10:12 PM Robert Metzger wrote: > Hey all, > > We've added another committer to the Flink project: Zhijiang Wang. > > Congratulations Zhijiang! > > Best, > Robert > (on behalf of the Flink PMC) >

Re: [ANNOUNCE] Kete Young is now part of the Flink PMC

2019-07-23 Thread Bo WANG
Congratulations Kurt! Best, Bo WANG On Tue, Jul 23, 2019 at 5:24 PM Robert Metzger wrote: > Hi all, > > On behalf of the Flink PMC, I'm happy to announce that Kete Young is now > part of the Apache Flink Project Management Committee (PMC). > > Kete has been a commit

Apply for flink contributor permission

2018-12-24 Thread Bo WANG
Hi, everyone We would like to make contribution to JIRA(FLINK-10644). Would anyone kindly give me and my team member the contribution permission? Our JIRA id: Ryantaocer, eaglewatcher. Best regards Bo

[DISCUSS] Shall we make SpillableSubpartition repeatedly readable to support fine grained recovery

2019-01-22 Thread Bo WANG
Hi all, When running the batch WordCount example, I configured the job execution mode as BATCH_FORCED, and failover-strategy as region, I manually injected some errors to let the execution fail in different phases. In some cases, the job could recovery from failover and became succeed, but in som

Re: [DISCUSS] Shall we make SpillableSubpartition repeatedly readable to support fine grained recovery

2019-01-27 Thread Bo WANG
(independent of the DataSet or Query Processor stack). > > > > > > I am adding Kurt to this thread - maybe he help us find that out. > > > > > > On Thu, Jan 24, 2019 at 2:36 PM Piotr Nowojski > > > wrote: > > > > > > > Hi

[DISCUSS] Adaptive Parallelism of Job Vertex

2019-04-08 Thread Bo WANG
Hi all, In distribution computing system, execution parallelism is vital for both resource efficiency and execution performance. In Flink, execution parallelism is a pre-specified parameter, which is usually an empirical value and thus might not be optimal on the various amount of data processed by

Re: [DISCUSS] Adaptive Parallelism of Job Vertex

2019-04-17 Thread Bo WANG
Thanks Till for the comments. We will implement a new adaptive parallelism supported scheduler in the new schedule framework. Based on these schedule interfaces, we could do the work in parallel. On Tue, Apr 16, 2019 at 11:18 PM Till Rohrmann wrote: > Hi Bo Wang, > > thanks for propo

Re: [ANNOUNCE] Jincheng Sun is now part of the Flink PMC

2019-06-24 Thread Bo WANG
Congratulations Jincheng! Well deserved! On Tue, Jun 25, 2019 at 10:10 AM Kurt Young wrote: > Congratulations Jincheng! > > Best, > Kurt > > > On Tue, Jun 25, 2019 at 9:56 AM LakeShen > wrote: > > > Congratulations! Jincheng Sun > > > > Best, > > LakeShen > > > > Robert Metzger 于2019年6月24日周一 下

[jira] [Created] (FLINK-23355) Use Flink SQL ,How to implement insert into seq to multi sinks?

2021-07-12 Thread Bo Wang (Jira)
Bo Wang created FLINK-23355: --- Summary: Use Flink SQL ,How to implement insert into seq to multi sinks? Key: FLINK-23355 URL: https://issues.apache.org/jira/browse/FLINK-23355 Project: Flink Issue