首页 > 数据库 > 数据库开发技术 > 三分钟带你了解Spark简介及架构设计
关注并标星 3分钟秒懂大数据
每天1次,打卡阅读
更快更全面获取大数据技术博客

1、Spark 简介


4.随处运行:Spark具有很强的适应性,能够读取HDFS、Cassandra、HBase、S3和Techyon为持久层读写原生数据,能够以Mesos、YARN和自身携带的Standalone作为资源管理器调度job,来完成Spark应用程序的计算。


Spark 模块划分:


Spark基础模块:Spark-Core;


2、Spark 架构


Spark 架构主要由以下几部分组成:
服务架构集群和资源管理 Master / Yarn Application Master
工作节点 Work / Node Manager
任务调度器 Driver
任务执行器 Executor


架构图

运行原理如下:
1、Spark 集群启动后,Work向Master注册信息;
2、Spark-submit命令提交程序后,Driver和Application也会向Master注册信息;
3、创建SparkContext对象,主要是包含DAGScheduler和TaskScheduler;
4、Driver把Application信息注册给 Maste后,Master会根据App信息去Work 节点启动Executor
5、Executor内部会创建运行task的线程池,然后把启动的Executor反向注册给Dirver;
6、DAGScheduler:负责把Spark作业转换成 DAG(有向无环图),根据宽窄依赖切分Stage,然后把 TaskSet的形式发送个给TaskScheduler, DAGScheduler还会处理由于Shuffle数据丢失导致的失败;
7、TaskScheduler:维护所有 Task,分发Task给各个节点的Executor(根据数据本地化策略分发)监控task的运行状态,负责重试失败的task;
8、所有task运行完成后,SparkContext 向Master注销,释放资源。


End

找各类大数据技术文章,就来
<3分钟秒懂大数据>
随时更新互联网大数据组件内容
专为学习者提供技术博文
快和身边的小伙伴一起关注我们吧!
原文作者:3分钟秒懂大数据;如有侵权,请联系管理员删除。