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
