I am not Flink master or regular user of FLink , but would like to start contributing to Flink. Would it be possible to get involved on this issues and start contributing to Flink community?
Thanks Deepak On Mon, May 23, 2016 at 10:49 PM, Ufuk Celebi <u...@apache.org> wrote: > On Mon, May 23, 2016 at 6:55 PM, wangzhijiang999 > <wangzhijiang...@aliyun.com> wrote: > > In summary, if one task set autoread as false, and when it notify the > > available buffer, there are some messages during this time to be > processed > > first, if one message belongs to another failed task, the autoread for > this > > channel would not be set true anymore. The only way is to cancel all the > > tasks in this channel to release the channel. Is it right? > > Yes, very good observation. In this sense the failure model of Flink > is baked in into the way the channels are multiplexed, which is a bad > thing (as you already noticed with your improved failover strategy). > > If you want, let me look into this issue on a high level and let's fix > this together as a first step. Let's have a chat about this by the end > of the week. Does this work for you? > > After that, we can continue with the flow control issue, which is > definitely a bigger task. > > – Ufuk > -- Thanks Deepak www.bigdatabig.com www.keosha.net
