Re: [jira] [Created] (FLINK-6167) Consider removing ArchivedExecutionGraph classes

2017-03-27 Thread David Wang
Hi Chesnay, If Acrhived* versions of ExecutionGraph classes have been removed, is there any way to retrieve data in ExecutionGraph from JobMaster via RPC? Some of our projects rely on the Archived* classes from Job Masters running in the cluster. Thanks, David 2017-03-22 22:11 GMT+08:00 Chesnay

Re: FLIP-6 and FLIP-12

2016-10-26 Thread David Wang
+1 sounds great! Thanks, David 2016-10-26 20:07 GMT+08:00 Till Rohrmann : > +1 for the changes and thanks for updating the Flips. > > Cheers, > Till > > On Wed, Oct 26, 2016 at 1:05 PM, Stephan Ewen wrote: > > > Hi all! > > > > I updated the wiki with the following: > > > > FLIP-12 (async I/O)

Re: [DISCUSS] Proposal for Asynchronous I/O in FLINK

2016-09-21 Thread David Wang
Hi Shannon, That's right. This FLIP aims to boost TPS of the task workers with async i/o operation. As what Stephan has mentioned, by placing static attribute to shared resources(like event pool, connection), it is possible to share those resources among different slots in the same JVM. I will m

Re: [DISCUSS] Proposal for Asynchronous I/O in FLINK

2016-09-19 Thread David Wang
ameter? > - Do you plan to also add a RichFunction variant of AsyncFunction? > - Does it make sense to add a timeout thread for async calls to be able to > cancel a request? > > Best, Fabian > > > 2016-09-18 12:22 GMT+02:00 David Wang : > > > Hi Henry, > > &g

Re: [DISCUSS] Proposal for Asynchronous I/O in FLINK

2016-09-18 Thread David Wang
Hi Henry, Here is the FLIP: https://cwiki.apache.org/confluence/pages/viewpage.action?pageId=65870673 Thanks, David 2016-09-15 12:26 GMT+08:00 Henry Saputra : > HI David, > > Thanks so much for the interest to contribute to Apache Flink. > > To help review and DISCUSS for new feature in Flink,