目录

• 1.YARN 产生背景
• 2.YARN概述
• 3.YARN架构（面试考点，务必要了解整个架构）
• 4.YARN执行流程（面试考点，务必要了解整个执行流程）
• 5.YARN环境搭建
• 6.提交作业到YARN上执行

1、YARN 产生背景

在Hadoop1.X时，MapReduce是Master/Slave的架构，1个JobTracker带多个TaskTracker
JobTracker：负责资源管理和作业调度
TaskTracker：定期向JT汇报本节点的健康状况、资源使用情况、作业执行情况；接受来自JT的命令：启动任务/杀死任务

• MapReduce1.x 存在的问题：单点故障&节点压力大不易扩展&不支持除了MapReduce之外的其他计算框架
  image.png

• 资源利用率低&集群之间不能共享资源&运维成本高、管理困难

  
  
  image.png

• 因此，催生了YARN的诞生
  有了YARN(集群资源管理)之后，可以运行多个不同类型的作业和多种不同的计算框架。可以把YARN理解为是 操作系统级别的资源调度框架 ，它让更多的计算框架(Spark、MapReduce、Storm、Flink等)运行在同一个集群中，不同的计算框架之间可以共享同一个HDFS集群上的数据、享受整体的资源调度。
  xxx on YARN的好处：与其他计算框架共享集群资源、按资源需要分配，进而提高集群资源的利用率
  xxx ：Spark、MapReduce、Storm、Flink
  

  image.png

2、YARN概述

• Yet Another Resource Negotiator
• 通用的资源管理系统
• 为上层应用提供统一的资源管理和调度

3、YARN架构（面试考点，务必要了解整个架构的执行流程）

1）ResourceManager：RM
整个集群同一时间提供服务的RM只有一个，负责集群资源的统一管理和调度；处理客户端的请求：提交一个作业、杀死一个作业；监控NM，一旦某个NM挂了，则该NM上运行的任务需要告诉我们的AM该如何处理；
2）NodeManager：NM
整个集群中有多个，负责自己本身节点资源管理和使用，定时向RM汇报本节点的资源使用情况；接受并处理来自RM的各种命令：启动Container；
处理来自AM的命令；单个节点的资源管理；
3）ApplicationMaster：AM
每个应用程序对应一个AM：MR、Spark，负责应用程序的管理；为应用程序向RM申请资源（core、memory），分配给内部task，需要与NM通信：启动/停止task，task是运行在Container里面，AM也是运行在Container里面的。
4）Container
封装了CPU、Memory等资源的一个容器；是一个任务运行环境的抽象
5）Client
提交作业；查看作业运行进度；杀死作业

image.png

4、YARN执行流程

image.png

5、YARN环境搭建(单节点)

1）使用版本

• hadoop-2.6.0-cdh5.7.0.tar.gz

2）修改配置文件

• etc/hadoop/mapred-site.xml
  （第一次使用的时候，会发现在etc/hadoop/目录下并没有mapred-site.xml文件，只有mapred-site.xml.template，此时只需要复制一份mapred-site.xml.template重命名为mapred-site即可）在终端输入如下命令：

#复制mapred-site.xml.template重命名为mapred-site.xml
cp mapred-site.xml.template  mapred-site.xml 
#打开mapred-site.xml 
vim mapred-site.xml 

把下面代码添加到mapred-site.xml 文件中即可

<property>
    <name>mapreduce.framework.name</name>
       <value>yarn</value>
   </property>

image.png

• etc/hadoop/yarn-site.xml
  同上，打开yarn-site.xml，把下面代码添加进去即可

<property>
        <name>yarn.nodemanager.aux-services</name>
        <value>mapreduce_shuffle</value>
    </property>

3）启动

sbin/start-yarn.sh

4）验证
jps：多次两个进程NodeManager、 ResourceManager
打开浏览器：http://localhost:8088/

image.png

5）停止

sbin/stop-yarn.sh

6、提交MapReduce作业到YARN上执行

在/home/hadoop/app/hadoop-2.6.0-cdh5.7.0/share/hadoop/mapreduce
路径下，有官方提供的MapReduce的案例jar包：hadoop-mapreduce-examples-2.6.0-cdh5.7.0.jar
在终端输入以下命令：

#这条命令是运行官方提供的计算pi的案例
hadoop jar hadoop-mapreduce-examples-2.6.0-cdh5.7.0.jar pi 2 3

在浏览器中输入 http://localhost:8088/ 可以看到刚刚提交的作业，刷新页面查看作业的运行状态。

image.png

image.png