答复:答复:how to understand the flink flow control

2015-08-10 Thread wangzhijiang999
Hi Ufuk,           Thank you for your instant reply and I have got the basic idea.             I am researching flink code now, and  if I have further specific questions next time, I will send to dev@flink.a.o . Best wishes, Zhijiang Wang ---

Re: 答复:how to understand the flink flow control

2015-08-10 Thread Ufuk Celebi
Good to hear. Answers to your questions are inline. I think we should move the discussion to the dev@flink.a.o list though if there are more questions. On Mon, Aug 10, 2015 at 9:29 AM, wangzhijiang999 wrote: > Hi Ufuk, > > >Thank you for your detail and clear explaination! I reviewed t

答复:how to understand the flink flow control

2015-08-10 Thread wangzhijiang999
Hi Ufuk,        Thank you for your detail and clear explaination!  I reviewed the code based on your info and got it clearly. For local transfer: When producer emits results to ResultPartition, it will request  Buffer from the pool. If there  are no available Buffer, it will wait .The ResultPart