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

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

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

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

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

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] Jincheng Sun is now part of the Flink PMC

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日周一 下

Re: [DISCUSS] Adaptive Parallelism of Job Vertex

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

[DISCUSS] Adaptive Parallelism of Job Vertex

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] Shall we make SpillableSubpartition repeatedly readable to support fine grained recovery

(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] Shall we make SpillableSubpartition repeatedly readable to support fine grained recovery

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

Apply for flink contributor permission

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