Re: A Question About Flink Network Stack

2019-06-18 Thread bupt_ljy
Hi Zhijiang, Thank you for the detailed explaination! Best Regards, Jiayi Liao Original Message Sender:zhijiangwangzhijiang...@aliyun.com.INVALID Recipient:dev...@flink.apache.org Date:Tuesday, Jun 18, 2019 17:34 Subject:Re: A Question About Flink Network Stack Hi Jiayi, Thanks for

Re: A Question About Flink Network Stack

2019-06-18 Thread zhijiang
Hi Jiayi, Thanks for concerning the network stack and you pointed out a very good question. Your understanding is right. In credit-based mode, on receiver side it has fixed exclusive buffers(credits) for each remote input channel to confirm every channel could receive data in parallel, not blo

A Question About Flink Network Stack

2019-06-18 Thread bupt_ljy
Hi all, I’m not very familiar with the network part of Flink. And a question occurs to me after I read most related source codes about network. I’ve seen that Flink uses the credit-based machanism to solve the blocking problem from receivers’ side, which means that one “slow” input channel won’t