Spark 源码分析 – BlockManagerMaster&Slave
BlockManagerMaster 只是维护一系列对BlockManagerMasterActor的接口, 所有的都是通过tell和askDriverWithReply从BlockManagerMasterActor获取数据 比较鸡肋的类 private[spark] class BlockManagerMaster(var driverActor: ActorRef) extends Logging { /** Remove a dead executor from the driver actor. This is only called on the driver side. */ def removeExecutor(execId: String) /** * Send the driver actor a heart beat from the slave. Returns true if everything works out, * false if the driver does not know about the given block manager, whic...