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 <[email protected]> 于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 >
