参考:Flink 源码阅读笔记（8）- Task 之间的数据传输

Task 之间的数据传输 #

{{ .Site.BaseURL }}

类 #

Task 类 #

task #

doRun #

StreamTask #

StreamTask 初始化 #

task AbstractInvokable #

TaskManagerRunner #