一、启动公平调度器

公平调度器的使用由属性yarn.resourcemanager.scheduler.class的设置所决定。YARN默认使用的是容量调度器，如果要使用公平调度器，需要将yarn-site.xml文件中的yarn.resourcemanager.scheduler.class设置为公平调度器的完全限定名。

1.1 配置 yarn-site.xml

[root@hadoop1 hadoop]# vim /usr/local/hadoop/etc/hadoop/yarn-site.xml 

添加如下内容：

<!--调度器类型指定为 Fair Scheduler-->
<property><name>yarn.resourcemanager.scheduler.class</name><value>org.apache.hadoop.yarn.server.resourcemanager.scheduler.fair.FairScheduler</value>
</property><!--指定 Fair Scheduler 具体配置文件位置-->
<property><name>yarn.scheduler.fair.allocation.file</name><value>/usr/local/hadoop/etc/hadoop/conf/fail-scheduler.xml</value>
</property>

创建 fail-scheduler.xml 文件

[root@hadoop1 hadoop]# mkdir conf
[root@hadoop1 hadoop]# touch ./conf/fail-scheduler.xml

添加如下内容：

<?xml version="1.0"?>
<allocations><queue name="root"><!--设置调度策略--><schedulingPolicy>fair</schedulingPolicy><!--允许提交任务的用户名和组--><aclSubmitApps>*</aclSubmitApps><!--允许管理任务的用户名和组--><aclAdministerApps>*</aclAdministerApps><!--默认队列--><queue name="default"><minResources>1024mb, 1vcores</minResources><maxResources>4096mb, 4vcores</maxResources></queue><!--离线队列--><queue name="offline"><!--最小资源--><minResources>1024mb, 1vcores</minResources><!--最大资源--><maxResources>4096mb, 2vcores</maxResources><!--最大同时运行application数量--><maxRunningApps>50</maxRunningApps></queue><!--实时队列--><queue name="realtime"><!--最小资源--><minResources>1024mb, 1vcores</minResources><!--最大资源--><maxResources>4096mb, 2vcores</maxResources><!--最大同时运行application数量--><maxRunningApps>50</maxRunningApps></queue>

二、同步配置文件

因为当前Hadoop环境是伪分布集群，所以只需要修改当前节点的yarn-s和fairscheduler.xml配置文件即可。如果Hadoop为分布式集群环境，还需要将相关配置文件通过scp命令同步到集群其他节点。

三、重启启动 YARN 集群

因为公平调度器需要修改YARN相关的配置文件，所以需要重启YARN集群才能使配置文件生效。YARN集群的启停操作如下所示。

[root@hadoop1 hadoop]# /usr/local/hadoop/sbin/stop-yarn.sh 
[root@hadoop1 hadoop]# /usr/local/hadoop/sbin/start-yarn.sh 

四、提交作业

以Hadoop自带的WordCount为例，使用公平调度器将MapReduce应用提交到root.offline队列中运行，具体操作如下所示。

[root@hadoop1 hadoop]# /usr/local/hadoop/bin/yarn jar share/hadoop/mapreduce/hadoop-mapreduce-examples-2.10.2.jar wordcount -Dmapreduce.job.queuename=root.offline /test/words.log /test/out

上面代码执行成功：

五、运行结果