1. 前言
对Flink中各个组件(JobMaster、TaskManager、Dispatcher等),其底层RPC框架基于Akka实现,本篇文章侧重剖析Flink中的Rpc框架实现机制及梳理其通讯流程。对Flink中各个组件(JobMaster、TaskManager、Dispatche
对Flink中各个组件(JobMaster、TaskManager、Dispatcher等),其底层RPC框架基于Akka实现,本篇文章侧重剖析Flink中的Rpc框架实现机制及梳理其通讯流程。对Flink中各个组件(JobMaster、TaskManager、Dispatche