hadoop集群安装规划

http://mp.weixin.qq.com/s?__biz=MzI5MDYxNjIzOQ==&mid=2247483999&idx=1&sn=016e4c4d0ba7bd96e9f2d2d5f8cbe0de&chksm=ec1c649fdb6bed89e74984c28859557f577cdfedcdcee3f67ad50a5097daaff0e67718c50121&mpshare=1&scene=23&srcid=06136e9eXqqwI9Vfl2bIWLiv#rd

在搭建Hadoop分布式集群之前，我们需要先准备好3台主机，分别安装好Linux系统，并完成Linux系统的网络配置和系统配置。

 

相关资料：史上最全的Linux资料包，视频、电子书、PPT应有尽有。领取办法：关注“大数据研习社”后，微信后台回复“Linux”，即可获得私密下载链接。

 

1.集群安装规划

1.1主机规划

这里我们选择3台主机搭建Hadoop3.0高可用的分布式集群，虽然节点有点少，但是足以完成分布式集群搭建，并进行合理的主机规划。

	master	slave1	slave2
Namenode	是	是	是
DataNode	是	是	是
ResourceManager	是	是	否
NodeManager	是	是	是
Journalnode	是	是	是
Zookeeper	是	是	是

大家需要注意的是：从Hadoop3.0开始支持更多的Namenode，因为我们只有3台机器，所以这3台机器都配置为Namenode，实际工作中Namenode也不宜过多，否则对集群造成压力。其他角色保持跟Hadoop2.x一致即可，如果Hadoop2.x集群不熟悉可以参考大讲台课程：http://www.dajiangtai.com/course/4.do

1.2软件规划

软件	版本	位数	说明
Jdk	Jdk1.8	64位	稳定版本
Centos	Centos6.5	64位	稳定版本
Zookeeper	Zookeeper3.4.6		稳定版本
Hadoop	Hadoop   3.0.0-alpha3		最新版本

需要注意的是：Hadoop3.0最低支持Java8，如果大家还在使用Java7或者更低版本，请升级到Java8。

1.3用户规划

出于权限考虑，Hadoop集群环境安装不要使用root用户，需要大家自己创建相关的用户和用户组，注意创建用户的时候需要设置密码。

节点名称	用户组	用户
Master	Hadoop	Hadoop3
Slave1	Hadoop	Hadoop3
Slave2	Hadoop	Hadoop3

1.4数据目录规划

在搭建Hadoop集群之前，需要规划好所有的软件目录和数据存放目录，便于后期的管理与维护。

目录名称	绝对路径
所有软件存放目录	/home/hadoop3/app
所有数据与日志存放目录	/home/hadoop3/data

 

2. 集群安装前的环境检查

2.1时钟同步

所有节点的系统时间要与当前时间保持一致，否则集群运行会出现异常。时钟同步在3台机器上都需要操作，这里以master节点为例。

首先查看master节点的当前系统时间

如果系统时间与当前网络时间不一致,进行以下操作。

[root@master ~]# cd /usr/share/zoneinfo/

[root@master zoneinfo]# ls          //找到Asia

[root@master zoneinfo]# cd Asia/            //进入Asia目录

[root@master Asia]# ls            //找到Shanghai

[root@master Asia]# cp /usr/share/zoneinfo/Asia/Shanghai /etc/localtime             //当前时区替换为上海

我们可以保持当前系统时间与NTP（网络时间协议）一致。

[root@master Asia]# yum install ntp   //如果ntp命令不存在，在线安装ntp

[root@master Asia]# ntpdate pool.ntp.org          //执行此命令同步日期时间

[root@master Asia]# date              //查看当前系统时间

2.2 hosts文件检查

为了便于集群的操作，所有节点的hosts文件需要配置静态ip与hostname之间的对应关系。

2.3禁用防火墙

学习环境下，大家可以将防火墙关闭掉。

在root用户下，查看防火墙状态

[root@master ~]# service iptables status

执行以下命令可以临时关闭防火墙

[root@master ~]#  service iptables stop

执行以下命令才可以永久关闭防火墙

[root@master ~]#  chkconfig iptables off   

如果防火墙状态如下，则说明防火墙已经关闭。

 

3. 配置SSH免密码通信

Hadoop 集群中各个节点间会通过 SSH 访问，每次访问都输入密码是不切实际的，所以需要配置各个节点间的 SSH 是无密码登录的。

首先在各个节点上生成公钥，这里以master节点、Hadoop3用户为例

[root@master ~]# su hadoop3            //切换到hadoop3用户下

[hadoop3@master root]$ cd        //切换到hadoop3用户目录

[hadoop3@master ~]$ mkdir .ssh

[hadoop3@master ~]$ ssh-keygen -t rsa        //执行命令一路回车，生成秘钥

[hadoop3@master ~]$cd .ssh

[hadoop3@master .ssh]$ ls

id_rsa  id_rsa.pub

[hadoop3@master .ssh]$ cat id_rsa.pub >> authorized_keys           //将公钥保存到authorized_keys认证文件中

[hadoop3@master .ssh]$ ls

authorized_keys  id_rsa  id_rsa.pub

[hadoop3@master .ssh]$ cd ..

[hadoop3@master ~]$ chmod 700 .ssh

[hadoop3@master ~]$ chmod 600 .ssh/*

[hadoop3@master ~]$ ssh master            //第一次执行需要输入yes

[hadoop3@master ~]$ ssh master            //第二次以后就可以直接访问

将另外2个节点中的共钥id_ras.pub拷贝到master节点中的authorized_keys文件中。

cat ~/.ssh/id_rsa.pub | ssh hadoop3@master 'cat >> ~/.ssh/authorized_keys' 

然后将master中的authorized_keys文件分发到其他2个节点上。

scp -r authorized_keys hadoop3@slave1:~/.ssh/

scp -r authorized_keys hadoop3@slave2:~/.ssh/

各个节点如果能通过ssh相互访问，且不需要输入密码，则代表ssh配置成功。

 

4. 脚本工具的使用

在master节点，hadoop3用户下创建/home/hadoop3/tools目录。

[hadoop3@master ~]$ mkdir /home/hadoop3/tools

cd /home/hadoop3/tools

将本地脚本文件上传至/home/hadoop3/tools目录下，这些脚本大家可以自己写， 如果不熟练也可以直接使用。

[hadoop3@master tools]$ rz deploy.conf

[hadoop3@master tools]$ rz deploy.sh

[hadoop3@master tools]$ rz runRemoteCmd.sh

[hadoop3@master tools]$ ls

deploy.conf  deploy.sh  runRemoteCmd.sh

查看一下deploy.conf配置文件内容。

[hadoop3@master tools]$ cat deploy.conf

master,all,namenode,zookeeper,resourcemanager,

slave1,all,slave,namenode,zookeeper,resourcemanager,

slave2,all,slave,datanode,zookeeper,

查看一下deploy.sh远程复制文件脚本内容。

[hadoop3@master tools]$ cat deploy.sh

#!/bin/bash

#set -x

if [ $# -lt 3 ]

then

  echo "Usage: ./deply.sh srcFile(or Dir) descFile(or Dir) MachineTag"

  echo "Usage: ./deply.sh srcFile(or Dir) descFile(or Dir) MachineTag confFile"

  exit

fi

src=$1

dest=$2

tag=$3

if [ 'a'$4'a' == 'aa' ]

then

  confFile=/home/hadoop3/tools/deploy.conf

else

  confFile=$4

fi

if [ -f $confFile ]

then

  if [ -f $src ]

  then

    for server in `cat $confFile|grep -v '^#'|grep ','$tag','|awk -F',' '{print $1}'`

    do

       scp $src $server":"${dest}

    done

  elif [ -d $src ]

  then

    for server in `cat $confFile|grep -v '^#'|grep ','$tag','|awk -F',' '{print $1}'`

    do

       scp -r $src $server":"${dest}

    done

  else

      echo "Error: No source file exist"

  fi

else

  echo "Error: Please assign config file or run deploy.sh command with deploy.conf in same directory"

fi

查看一下runRemoteCmd.sh远程执行命令脚本内容。

[hadoop3@master tools]$ cat runRemoteCmd.sh

#!/bin/bash

#set -x

if [ $# -lt 2 ]

then

  echo "Usage: ./runRemoteCmd.sh Command MachineTag"

  echo "Usage: ./runRemoteCmd.sh Command MachineTag confFile"

  exit

fi

cmd=$1

tag=$2

if [ 'a'$3'a' == 'aa' ]

then

  confFile=/home/hadoop3/tools/deploy.conf

else

  confFile=$3

fi

if [ -f $confFile ]

then

    for server in `cat $confFile|grep -v '^#'|grep ','$tag','|awk -F',' '{print $1}'`

    do

       echo "*******************$server***************************"

       ssh $server "source /etc/profile; $cmd"

    done

else

  echo "Error: Please assign config file or run deploy.sh command with deploy.conf in same directory"

fi

以上三个文件，方便我们搭建hadoop3分布式集群。具体如何使用看后面如何操作。

如果我们想直接使用脚本，还需要给脚本添加执行权限。

[hadoop3@master tools]$ chmod u+x deploy.sh

[hadoop3@master tools]$ chmod u+x runRemoteCmd.sh

同时我们需要将/home/hadoop3/tools目录配置到PATH路径中。

[hadoop3@master tools]$vi ~/.bashrc

PATH=/home/hadoop3/tools:$PATH

export PATH

我们在master节点上，通过runRemoteCmd.sh脚本，一键创建所有节点的软件安装目录/home/hadoop3/app。

[hadoop3@master tools]$ runRemoteCmd.sh "mkdir /home/hadoop3/app" all

我们可以在所有节点查看到/home/hadoop3/app目录已经创建成功。

 

5. jdk安装

下载jdk1.8至本地，然后将jdk1.8上传至/home/hadoop3/app目录下。

[hadoop3@master app]$  ls

jdk-8u51-linux-x64.tar.gz

解压

[hadoop3@master app]$ tar –zxvf  jdk-8u51-linux-x64.tar.gz

删除安装包

[hadoop3@master app]$ rm –rf jdk-8u51-linux-x64.tar.gz

[hadoop3@master app]$  ls

jdk1.8.0_51

创建jdk软链接

[hadoop3@master app]$ ln –s jdk1.8.0_51  jdk

在hadoop3用户下，配置jdk环境变量

[hadoop3@master app]$ vi  ~/.bashrc

JAVA_HOME=/home/hadoop3/app/jdk

CLASSPATH=.:$JAVA_HOME/lib/dt.jar:$JAVA_HOME/lib/tools.jar

PATH=$JAVA_HOME/bin:/home/hadoop3/tools:$PATH

export JAVA_HOME CLASSPATH PATH

生效配置文件

[hadoop3@master app]$ source  ~/.bashrc

确认jdk配置成功

[hadoop3@master app]$ java -version

java version "1.8.0_51"

Java(TM) SE Runtime Environment (build 1.8.0_51-b16)

Java HotSpot(TM) 64-Bit Server VM (build 25.51-b03, mixed mode)

通过deploy.sh脚本将jdk安装目录分发到另外两个节点

[hadoop3@master app]$ deploy.sh jdk1.8.0_51 /home/hadoop3/app/ slave

在另外两个节点做相关操作，完成jdk配置

 

6. Zookeeper安装

下载zookeeper-3.4.6.tar.gz安装包，然后上传至/home/hadoop3/app目录

6.1解压

[hadoop3@master app]$ ls

zookeeper-3.4.6.tar.gz

[hadoop3@master app]$ tar –zxvf zookeeper-3.4.6.tar.gz

[hadoop3@master app]$ ls

zookeeper-3.4.6

[hadoop3@master app]$ rm –rf zookeeper-3.4.6.tar.gz

6.2修改配置文件

[hadoop3@master app]$ cd zookeeper-3.4.6/conf/

[hadoop3@master conf]$ ls

configuration.xsl  log4j.properties  zoo_sample.cfg

[hadoop3@master conf]$ cp  zoo_sample.cfg  zoo.cfg

[hadoop3@master conf]$vi zoo.cfg

# The number of milliseconds of each tick

tickTime=2000

# The number of ticks that the initial

# synchronization phase can take

initLimit=10

# The number of ticks that can pass between

# sending a request and getting an acknowledgement

syncLimit=5

# the directory where the snapshot is stored.

# do not use /tmp for storage, /tmp here is just

# example sakes.

dataDir=/home/hadoop3/data/zookeeper/zkdata

dataLogDir=/home/hadoop3/data/zookeeper/zkdatalog

# the port at which the clients will connect

clientPort=2181

# the maximum number of client connections.

# increase this if you need to handle more clients

#maxClientCnxns=60

#

# Be sure to read the maintenance section of the

# administrator guide before turning on autopurge.

#

# http://zookeeper.apache.org/doc/current/zookeeperAdmin.html#sc_maintenance

#

# The number of snapshots to retain in dataDir

#autopurge.snapRetainCount=3

# Purge task interval in hours

# Set to "0" to disable auto purge feature

#autopurge.purgeInterval=1

server.1=master:2888:3888

server.2=slave1:2888:3888

server.3=slave2:2888:3888

备注：

1 2 3代表服务编号；2888代表Zookeeper节点通信端口；3888代表zook选举端口

6.3远程拷贝

通过远程脚本deploy.sh将Zookeeper安装目录拷贝到其他节点。

[hadoop3@master app]$ deploy.sh zookeeper-3.4.6 /home/hadoop3/app/ slave

所有节点创建数据目录和日志目录

[hadoop3@master app]$ runRemoteCmd.sh "mkdir -p /home/hadoop3/data/zookeeper/zkdata" all 

[hadoop3@master app]$ runRemoteCmd.sh "mkdir -p /home/hadoop3/data/zookeeper/zkdatalog" all 

6.4创建myid文件

在各个节点上，在 dataDir 所指定的目录下创一个名为 myid 的文件， 文件内容为各个server 点后面的数字。

[hadoop3@master zkdata]$ vi myid

[hadoop3@slave1 zkdata]$ vi myid

[hadoop3@slave2 zkdata]$ vi myid

6.5测试运行

使用runRemoteCmd.sh 脚本，启动所有节点上面的Zookeeper。

[hadoop3@master zookeeper-3.4.6]$runRemoteCmd.sh "/home/hadoop3/app/zookeeper-3.4.6/bin/zkServer.sh start" zookeeper

查看所有节点上面的QuorumPeerMain进程是否启动。

[hadoop3@master zookeeper-3.4.6]$ runRemoteCmd.sh "jps" all

查看所有Zookeeper节点状态。

[hadoop3@master zookeeper-3.4.6]$ runRemoteCmd.sh "/home/hadoop3/app/zookeeper-3.4.6/bin/zkServer.sh status" all

如果一个节点为leader，另两个节点为follower，则说明Zookeeper安装成功。

 

7.Hadoop3.0分布式集群搭建

7.1配置HDFS

7.1.1下载解压Hadoop3.0

到Hadoop官网下载hadoop-3.0.0-alpha2.tar.gz，并上传至/home/hadoop3/app目录

[hadoop3@master app]$ ls

hadoop-3.0.0-alpha2.tar.gz

[hadoop3@master app]$tar –zxvf hadoop-3.0.0-alpha2.tar.gz

[hadoop3@master app]$ ls

hadoop-3.0.0-alpha2.tar.gz  hadoop-3.0.0-alpha3

[hadoop3@master app]$ rm –rf hadoop-3.0.0-alpha2.tar.gz

[hadoop3@master app]$ mv hadoop-3.0.0-alpha3 hadoop-3.0.0

7.1.2配置hadoop-env.sh

[hadoop3@master app]$ cd hadoop-3.0.0/etc/hadoop/

[hadoop3@master hadoop]$ vi hadoop-env.sh

export JAVA_HOME=/home/hadoop3/app/jdk

export HADOOP_HOME=/home/hadoop3/app/hadoop

7.1.3配置core-site.xml

[hadoop3@master hadoop]$ vi core-site.xml

<configuration>

       <property>

         <name>fs.defaultFS</name>

         <value>hdfs://mycluster</value>

       </property>

       <property>

         <name>hadoop.tmp.dir</name>

         <value>/home/hadoop3/data/tmp</value>

       </property>

       <property>

          <name>ha.zookeeper.quorum</name>

          <value>master:2181,slave1:2181,slave2:2181</value>

       </property>

</configuration>

7.1.4配置hdfs-site.xml

[hadoop3@master hadoop]$ vi  hdfs-site.xml

<configuration>

       <property>

         <name>dfs.nameservices</name>

         <value>mycluster</value>

       </property>

       <property>

      <name>dfs.permissions.enabled</name>

      <value>false</value>

    </property>

       <property>

         <name>dfs.ha.namenodes.mycluster</name>

         <value>nn1,nn2,nn3</value>

       </property>

       <property>

         <name>dfs.namenode.rpc-address.mycluster.nn1</name>

         <value>master:9820</value>

       </property>

       <property>

         <name>dfs.namenode.rpc-address.mycluster.nn2</name>

         <value>slave1:9820</value>

       </property>

       <property>

         <name>dfs.namenode.rpc-address.mycluster.nn3</name>

         <value>slave2:9820</value>

       </property>

       <property>

         <name>dfs.namenode.http-address.mycluster.nn1</name>

         <value>master:9870</value>

       </property>

       <property>

         <name>dfs.namenode.http-address.mycluster.nn2</name>

         <value>slave1:9870</value>

       </property>

       <property>

         <name>dfs.namenode.http-address.mycluster.nn3</name>

         <value>slave2:9870</value>

       </property>

       <property>

      <name>dfs.ha.automatic-failover.enabled</name>

      <value>true</value>

     </property>

       <property>

         <name>dfs.namenode.shared.edits.dir</name>

         <value>qjournal://master:8485;slave1:8485;slave2:8485/mycluster</value>

       </property>

       <property>

         <name>dfs.journalnode.edits.dir</name>

         <value>/home/hadoop3/data/journaldata/jn</value>

       </property>

       <property>

         <name>dfs.client.failover.proxy.provider.mycluster</name>

         <value>org.apache.hadoop.hdfs.server.namenode.ha.ConfiguredFailoverProxyProvider</value>

       </property>

       <property>

      <name>dfs.ha.fencing.methods</name>

      <value>sshfence</value>

    </property>

    <property>

      <name>dfs.ha.fencing.ssh.private-key-files</name>

      <value>/home/hadoop3/.ssh/id_rsa</value>

    </property>

       <property>

      <name>dfs.ha.fencing.ssh.connect-timeout</name>

      <value>10000</value>

    </property>

    <property>

      <name>dfs.namenode.handler.count</name>

      <value>100</value>

    </property>

       <property>

          <name>dfs.ha.automatic-failover.enabled</name>

          <value>true</value>

        </property>

</configuration>

7.1.5配置workers

[hadoop3@master hadoop]$ vi workers

master

slave1

slave2

注意：hadoop2.x配置的是slaves文件，这里有所改变。

7.1.6将hadoop3.0安装包分发到其他节点

[hadoop3@master app]$ deploy.sh hadoop-3.0.0 /home/hadoop3/app/ slave

7.1.7创建hadoop3.0软连接

在所有节点上创建hadoop3.0软连接，这里以master节点为例。

[hadoop3@master app]$ ln -s hadoop-3.0.0 hadoop

[hadoop3@master app]$ ls

hadoop  hadoop-3.0.0

7.1.8配置hadoop3.0环境变量

在所有节点上配置hadoop3.0环境变量，这里以master节点为例

[hadoop3@master app]$ vi ~/.bashrc

JAVA_HOME=/home/hadoop3/app/jdk

HADOOP_HOME=/home/hadoop3/app/hadoop

CLASSPATH=.:$JAVA_HOME/lib/dt.jar:$JAVA_HOME/lib/tools.jar

PATH=$JAVA_HOME/bin:HADOOP_HOME/bin:$PATH

export JAVA_HOME CLASSPATH PATH HADOOP_HOME

7.1.9格式化hdfs

第一次安装hdfs的时候，需要对hdfs进行相关的格式化操作，以后就不需要了。

7.1.9.1先启动Zookeeper

[hadoop3@master app]$runRemoteCmd.sh "/home/hadoop3/app/zookeeper-3.4.6/bin/zkServer.sh start" all

7.1.9.2接着启动journalnode

[hadoop3@master app]$ runRemoteCmd.sh "/home/hadoop3/app/hadoop/sbin/hadoop-daemon.sh start journalnode" all

7.1.9.3在master节点上执行格式化

[hadoop3@master hadoop]$ bin/hdfs namenode -format / /namenode 格式化

[hadoop3@master hadoop]$ bin/hdfs zkfc -formatZK //格式化高可用

[hadoop3@master hadoop]$bin/hdfs namenode //启动namenode

7.1.9.4备用节点slave1 slave2通过master节点元数据信息，分别在slave1、slave2节点上执行。

[hadoop3@slave1 hadoop]$ bin/hdfs namenode -bootstrapStandby

[hadoop3@slave2 hadoop]$ bin/hdfs namenode -bootstrapStandby

7.1.9.5slave1 slave2节点同步完master上的元数据之后，在master节点上按下ctrl+c来结束namenode进程。

7.1.9.6 关闭所有节点journalnode

[hadoop3@master app]$ runRemoteCmd.sh "/home/hadoop3/app/hadoop/sbin/hadoop-daemon.sh stop journalnode" all

7.1.10 启动HDFS

一键启动hdfs

[hadoop3@master hadoop]$ sbin/start-dfs.sh

7.1.11 测试运行HDFS

7.1.11.1查看HDFS Web界面，这里配置的master slave1 slave2节点都为namenode。

关闭active状态的namenode，检查是否会自动切换其他节点

7.1.11.2测试hdfs文件上传

[hadoop3@master hadoop]$ vi djt.txt   

hadoop

hadoop

hadoop

dajiangtai

dajiangtai

dajiangtai

[hadoop3@master hadoop]$ bin/hdfs dfs -mkdir /dajiangtai  

[hadoop3@master hadoop]$ bin/hdfs dfs -put djt.txt /dajiangtai  

[hadoop3@master hadoop]$ bin/hdfs dfs -cat /dajiangtai/djt.txt

7.2配置YARN

7.2.1配置mapred-site.xml

[hadoop3@master hadoop]$ vi  mapred-site.xml

<configuration>

<property>

       <name>mapreduce.framework.name</name>

       <value>yarn</value>

</property>

<property>

       <name>mapreduce.application.classpath</name>

       <value>

       /home/hadoop3/app/hadoop/etc/hadoop,

        /home/hadoop3/app/hadoop/share/hadoop/common/*,

        /home/hadoop3/app/hadoop/share/hadoop/common/lib/*,

        /home/hadoop3/app/hadoop/share/hadoop/hdfs/*,

        /home/hadoop3/app/hadoop/share/hadoop/hdfs/lib/*,

        /home/hadoop3/app/hadoop/share/hadoop/mapreduce/*,

        /home/hadoop3/app/hadoop/share/hadoop/mapreduce/lib/*,

        /home/hadoop3/app/hadoop/share/hadoop/yarn/*,

        /home/hadoop3/app/hadoop/share/hadoop/yarn/lib/*

       </value>

</property>

</configuration>

7.2.2配置yarn-site.xml

[hadoop3@master hadoop]$ vi  yarn-site.xml

<configuration>

<property>

       <name>yarn.resourcemanager.connect.retry-interval.ms</name>

       <value>2000</value>

</property>

<property>

       <name>yarn.resourcemanager.ha.enabled</name>

       <value>true</value>

</property>

<property>

       <name>yarn.resourcemanager.ha.automatic-failover.enabled</name>

       <value>true</value>

</property>

<property>

       <name>yarn.resourcemanager.ha.automatic-failover.embedded</name>

       <value>true</value>

</property>

<property>

       <name>yarn.resourcemanager.cluster-id</name>

       <value>yarn-rm-cluster</value>

</property>

<property>

       <name>yarn.resourcemanager.ha.rm-ids</name>

       <value>rm1,rm2</value>

</property>

<property>

       <name>yarn.resourcemanager.hostname.rm1</name>

       <value>master</value>

</property>

<property>

       <name>yarn.resourcemanager.hostname.rm2</name>

       <value>slave1</value>

</property>

<property>

       <name>yarn.resourcemanager.recovery.enabled</name>

       <value>true</value>

</property>

<property>

   <description>The class to use as the persistent store.</description>

   <name>yarn.resourcemanager.store.class</name>

   <value>org.apache.hadoop.yarn.server.resourcemanager.recovery.ZKRMStateStore</value>

 </property>

<property>

       <name>yarn.resourcemanager.zk.state-store.address</name>

       <value>master:2181,slave1:2181,slave2:2181</value>

</property>

<property>

       <name>yarn.resourcemanager.zk-address</name>

       <value>master:2181,slave1:2181,slave2:2181</value>

</property>

<property>

       <name>yarn.resourcemanager.address.rm1</name>

       <value>master:8032</value>

</property>

<property>

       <name>yarn.resourcemanager.scheduler.address.rm1</name>

       <value>master:8034</value>

</property>

<property>

       <name>yarn.resourcemanager.webapp.address.rm1</name>

       <value>master:8088</value>

</property>

<property>

       <name>yarn.resourcemanager.address.rm2</name>

       <value>slave1:8032</value>

</property>

<property>

       <name>yarn.resourcemanager.scheduler.address.rm2</name>

       <value>slave1:8034</value>

</property>

<property>

       <name>yarn.resourcemanager.webapp.address.rm2</name>

       <value>slave1:8088</value>

</property>

<property>

       <name>yarn.nodemanager.aux-services</name>

       <value>mapreduce_shuffle</value>

</property>

<property>

       <name>yarn.nodemanager.aux-services.mapreduce_shuffle.class</name>

       <value>org.apache.hadoop.mapred.ShuffleHandler</value>

</property>

</configuration>

7.2.3脚本分发修改的yarn配置

[hadoop3@master hadoop]$ deploy.sh mapred-site.xml /home/hadoop3/app/hadoop-3.0.0/etc/hadoop/ slave

[hadoop3@master hadoop]$ deploy.sh yarn-site.xml

/home/hadoop3/app/hadoop-3.0.0/etc/hadoop/ slave

7.2.4启动yarn

在master节点启动resourcemanager

[hadoop3@master hadoop]$ bin/yarn --daemon start resourcemanager

在slave1节点启动resourcemanager

[hadoop3@slave1  hadoop]$ bin/yarn --daemon start resourcemanager

在3个节点分别启动nodemanager

[hadoop3@master  hadoop]$ bin/yarn --daemon start nodemanager [hadoop3@slave1  hadoop]$ bin/yarn --daemon start nodemanager [hadoop3@slave2  hadoop]$ bin/yarn --daemon start nodemanager

7.2.5 通过Web查看YARN

7.2.6检查ResourceManager状态

关闭active 状态的resourcemanager，检查另外一个节点是否能称为active状态。

7.2.7测试运行WordCount

[hadoop3@master hadoop]$ bin/hadoop jar share/hadoop/mapreduce/hadoop-mapreduce-examples-3.0.0-alpha2.jar wordcount /dajiangtai/djt.txt /dajiangtai/output

查看yarn的Web界面

查看运行结果

[hadoop3@master hadoop]$ bin/hdfs dfs -cat /dajiangtai/output/*

如果以上操作没有问题，说明Hadoop3.0分布式高可用集群成功搭建完毕。