Re: How does TaskManager announce JobManager about available ResultPartitions?

[Zhu Zhu]

Hi Joseph,

The availability of pipelined result partition is notified to JM via scheduleOrUpdateConsumers RPC.

Just want to mention that it's better to send such questions to the user mail list.

Thanks,

Zhu Zhu

Fork Joseph <[hidden email]> 于2020年7月21日周二 上午3:30写道：

Hi,

According to description in
https://cwiki.apache.org/confluence/display/FLINK/Data+exchange+between+tasks,
TaskManager announces (tells) JobManager about available
ResultSubpartitions  (RSs) to let another TM to initiate the transfer.
However, I can’t find where in the codebase TM actually announces JM about
RSs for streaming (Pipelined) mode.

Thanks!
Joseph