在集群上运行Spark应用的详细过程

标签：stop   释放   并保存   通过   资源   发送   保存   过程   并且   

在集群上运行Spark应用的详细过程：

（1）用户通过spark-submit脚本提交应用

（2）spark-submit脚本启动驱动器程序，调用用户定义的main()方法

（3）驱动器程序与集群管理器通信，申请资源以启动执行器节点

（4）集群管理器为驱动器程序启动执行器节点

（5）驱动器进程执行用户应用中的操作。根据程序中所定义的对RDD的转换操作和行动操作，驱动器节点把动作以任务的形式发送到执行器进程

（6）任务在执行器程序中进行计算并保存结果

（7）如果驱动器程序的main()方法退出，或者调用了SparkContext.stop()，驱动器程序会终止执行器进程，并且通过集群管理器释放资源

在集群上运行Spark应用的详细过程

标签：stop   释放   并保存   通过   资源   发送   保存   过程   并且   

原文地址：http://www.cnblogs.com/reedom1991/p/7115940.html