`

spark-学习笔记--18 spark1.3 worker解析

 
阅读更多

spark1.3  worker解析

 



 

 

Driver:

DriverRunner 创建Driver工作目录、 将用户jar包下载到工作目录中 

             使用 ProcessBuilder 启动进程

                 对Driver的退出状态进行处理

DriverRunner 向他所属的worker 和 actor 发送一个 DriverStateChanged事件 

worker 将DriverStateChanged事件 发送给 master   ,master会进行状态改变处理

    将Driver从本地缓存移除

    将Driver的内存和 cpu释放

 

 

executor:

    创建executor的本地工作目录

    创建executorRunner

    创建一个线程:

   重定向输出流 stdout  stderr

   启动executor进程

   拿到进程返回的状态

   想 executorRunner线程所属的 worker actor发送 executorChanged消息

 

worker 接受到 executorChanged 向master发送 executorChanged消息  ,  master进行状态改变处理

   

    把executorRunner加入本地缓存

启动 executorRunner

 

加上 executorRunner要使用的资源

 

 

  • 大小: 30.9 KB
分享到:
评论

相关推荐

Global site tag (gtag.js) - Google Analytics