flink-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From David Herzog <hd2...@googlemail.com>
Subject TaskManager Transfer buffers
Date Tue, 09 Aug 2016 16:41:04 GMT
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

Mime
  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message