Flink内部之间的通信

  • Akka:Flink内部节点(组件)之间的通信是用,比如JobManager和TaskManager之间的通信。
  • Netty:operator之间的数据传输。
  • RPC框架:组件通信的总称;Akka、Netty等都是它的具体实现。
  • Flink整个通信框架的组件主要由RpcEndpoint、RpcService、RpcServer、AkkaInvocationHandler、AkkaRpcActor等构成。
请使用浏览器的分享功能分享到微信等