Re: TaskManager Transfer buffers

2016-08-15 Thread Ufuk Celebi
Hey David! Yes, sure. - The NettyServer handles these requests in the server pipeline (see PartitionRequestProtocol#getServerChannelHandlers()) - The main handler for these requests is PartitionRequestServerHandler: it gets the requests, forwards it to the ResultPartitionProvider and queues it for

TaskManager Transfer buffers

2016-08-09 Thread David Herzog
Hi dear Support, I am currently working on a research project and have to understand how the transfer of buffers exactly works. https://cwiki.apache.org/confluence/display/FLINK/Data+exchange+between+tasks This page describes how a request for a ResultSubpartion works. I got to the part that *Part