LocalInputChannel 是上下游的 Task 部署在同一个 TaskManager 时使用的,在本地即可完成数据交换,无需网络通信。当上下游的 Task 部署在不同的 TaskManager 时,就需要用到 RemoteInputChannel,Flink 利用 Netty 来进行数据交互。本文我们来一起梳理一下 Netty 相关的源码。
Flink源码阅读:Netty通信
未经允许不得转载:小狮博客 » Flink源码阅读:Netty通信
LocalInputChannel 是上下游的 Task 部署在同一个 TaskManager 时使用的,在本地即可完成数据交换,无需网络通信。当上下游的 Task 部署在不同的 TaskManager 时,就需要用到 RemoteInputChannel,Flink 利用 Netty 来进行数据交互。本文我们来一起梳理一下 Netty 相关的源码。