spark之master与worker通信模型讲解

通信模型架构图 master 端代码 import akka.actor.{Actor, ActorSystem, Props} import com.typesafe.config.ConfigFactory // 需要导入这2个包 封装一些属性。 class MasterActor extends Actor {   //在开始之前调用一次   override def preStart()

>>阅读原文<<