Celebi 发送时间：2016年5月24日(星期二) 01:19收件人：user
; wangzhijiang999 主 题：Re:
problem of sharing TCP connection when transferring data On Mon, May 23, 2016
at 6:55 PM, wangzhijiang999
wrote:
>In summary, if one task set autoread as false, and when it notify the
> available buffer, there ar
Thanks Ufuk.
Sure I would pick some starter issues and get to these low level issues.
-Deepak
On 23 May 2016 11:21 pm, "Ufuk Celebi" wrote:
> On Mon, May 23, 2016 at 7:30 PM, Deepak Sharma
> wrote:
> > Would it be possible to get involved on this issues and start
> contributing
> > to Flink com
On Mon, May 23, 2016 at 7:30 PM, Deepak Sharma wrote:
> Would it be possible to get involved on this issues and start contributing
> to Flink community?
Hey Deepak!
Nice to see that you are also interested in this. If you are new to
Flink I would recommend to start contributing by looking into o
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 wrote:
> On Mon, May 23, 2016 at 6:55 PM, wa
On Mon, May 23, 2016 at 6:55 PM, wangzhijiang999
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 wo
application, and wish further contact with you for the professional advise.
Thank you again!
Zhijiang
Wang--发件人：Ufuk
Celebi 发送时间：2016年5月23日(星期一) 19:49收件人：user
; wangzhijiang999 主 题：Re:
problem of sharing TCP connection when
Yes, that is a correct description of the state of things.
A way to improve this is to introduce flow control in the application
layer, where consumers only receive buffers when they have buffers
available. They could announce on the channel how many buffers they
have before they receive anything.
Hi,
I am confused with sharing tcp connection for the same connectionID, if
two tasks share the same connection, and there is no available buffer in the
local buffer pool of the first task , then it will set autoread as false for
the channel, but it will effect the second task if it still
