Flink内部之间的通信
元亨利贞
2023-03-05 21:09:12
数据分析
原创
Akka:Flink内部节点(组件)之间的通信是用,比如JobManager和TaskManager之间的通信。
Netty:operator之间的数据传输。
RPC框架:组件通信的总称;Akka、Netty等都是它的具体实现。
Flink整个通信框架的组件主要由RpcEndpoint、RpcService、RpcServer、AkkaInvocationHandler、AkkaRpcActor等构成。
CDH6.3的Kafka消费不到消息
yarn-per-job提交流程