FlinkFLink 通讯组件 Akka与Actor 模型

Posted 2021-09-05 九师兄

1.概述

本博客是 视频的笔记，这个是讲解 flink 1.12 源码的，入门非常的好。

尚硅谷2021最新Flink内核源码解析课程（从入门到精通）

2.介绍

Flink内部节点之间的通信是用Akka，比如JobManager和TaskManager之间的通信。而operator之间的数据传输是利用Netty。

Flink通过Akka进行的分布式通信的实现，在0.9版中采用。使用Akka，所有远程过程调用现在都实现为异步消息。这主要影响组件JobManager，TaskManager 和JobClient。

将来，甚至有可能将更多的组件转换为参与者，从而允许它们发送和处理异步消息。RPC框架是Flink任务运行的基础，Flink整个RPC框架基于Akka实现，并对Akka中的ActorSys