集群RPC通信机制 #

Flink RPC框架的整体设计 #

Flink RPC框架与Akka的关系 #

运行时RPC整体架构设计 #

AkkaRpcService #

初始化 #

方法 #

初始化 RpcServer #

以TaskManager为例

RpcEndpoint 的设计与实现 #

RpcEndPoint与RpcServer的启动 #

ResourceManager

AkkaRpcService连接RpcServer并创建RpcGateway #

RpcServer动态代理实现 #

AkkaRpcActor的设计与实现 #

集群组件之间的RPC通信 #

RegisteredRpcConnection #

TaskExecutorToResourceManagerConnection #

TaskManager向ResourceManager注册RPC服务 #