基於akka的flink RPC調用

 flink中的rpc框架使用的akka。在本節並不詳細講述akka,而是就flink中rpc來講述akka的部分內容。本節,我從AkkaRpcActor.handleRpcInvocation方法講起。   看過hadoop、yarn、hive、hbase、presto的rpc框架,感覺flink的通信框架是最容易讓人繞暈的。雖然之前也看過一點spark中akka的通信,但現在早已忘得一乾二淨。
相關文章
相關標籤/搜索