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 *PartitionRequestClient.requestSubpartition()* actually sends the request to the other task, but I couldn't figure out how and where this request is received and processed in the receiving task. I would be very happ if you could help me trying to understand where requests for ResultSubpartitions from other Tasks are handled and how the ResultPartition actually answers those request. Thank you in advance :)
Regards David Herzog
