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