Skip to content

hadoop

环境

初始化

1. 启动三台服务器

准备 3 台虚拟机,2CPU 4G 50G. hadoop001 hadoop002 hadoop003

multipass 的方式启动对应三台

# 进入对应shell
multipass shell hadoop001
...

设置对应服务器名(multipass已有,不用再处理)
vim /etc/hostname

2. 配置清华源

参考:https://mirrors.tuna.tsinghua.edu.cn/help/ubuntu/ 修改配置后

sudo apt upgrade
sudo apt update

3. 基本环境处理

安装 net-tools

sudo apt install net-tools

确保可以 ping 通外网

关闭且禁用防火墙

sudo ufw disable

sudo ufw status 当显示 Status: inactive 则为关闭且禁用的状态

添加 hosts

vim /etc/hosts

xxx.xxx.xxx.xxx hadoop001
xxx.xxx.xxx.xxx hadoop002
xxx.xxx.xxx.xxx hadoop003

创建用户

使用multipass,直接用默认ubuntu用户,可以忽略以下步骤

root 下创建 shadoop 用户,且设置密码 shadoop useradd shadooppasswd shadoop

配置 shadoop 用户 root 权限,方便需要 sudo 的命令vim /etc/sudoers添加shadoop ALL=(ALL) NOPASSWD:ALL

创建目录 /opt/module /opt/software

创建两个文件夹mkdir /opt/module,mkdir /opt/software
修改用户组chown shadoop:shadoop /opt/module,chown shadoop:shadoop /opt/software

shell
# 这里用的multipass创建的实例,所以直接用默认ubuntu用户名
sudo mkdir /opt/module
sudo mkdir /opt/software
sudo chown ubuntu:ubuntu /opt/module
sudo chown ubuntu:ubuntu /opt/software

查看ll

配置ssh

配置 hadoop001,hadoop002,hadoop003 的 ubuntu 用户相互 ssh 免密访问

配置 hadoop001 的 root 用户到hadoop002,hadoop003 的 ssh 免密访问

生成 sshssh-keygen -t rsa

4. 安装jdk

安装 openjdksudo apt install openjdk-8-jdk

安装 openjdk 后配置 JAVA_HOME 变量到 shell

sudo vim /etc/profile.d/my_env.sh

#JAVA_HOME
JAVA_HOME=/usr/lib/jvm/java-1.8.0-openjdk-amd64

#mac m
JAVA_HOME=/usr/lib/jvm/java-8-openjdk-arm64

# 公共
export PATH=$JAVA_HOME/bin:$PATH
export CLASSPATH=.:$JAVA_HOME/lib/dt.jar:$JAVA_HOME/lib/tools.jar

4. 安装hadoop

下载hadoop-3.1.3.tar.gz/opt/software hadoop001

下载慢的话,下载到宿主机,scp 到 hadoop001 scp hadoop-3.1.3.tar.gz ubuntu@hadoop001:/opt/software

解压tar -zxvf hadoop-3.1.3.tar.gz -C /opt/module/

将 hadoop 添加到环境变量

sudo vim /etc/profile.d/my_env.sh

#HADOOP_HOME
export HADOOP_HOME=/opt/module/hadoop-3.1.3
export PATH=$PATH:$HADOOP_HOME/bin
export PATH=$PATH:$HADOOP_HOME/sbin

source /etc/profile

验证 hadoop version

如果出现ERROR: JAVA_HOME is not set and could not be found.

vim /opt/module/hadoop-3.1.3/etc/hadoop/hadoop-env.sh

# 添加
export JAVA_HOME=/usr/lib/jvm/java-8-openjdk-arm64
export HADOOP_HOME=/opt/module/hadoop-3.1.3

正确显示

$ hadoop version
Hadoop 3.1.3
Source code repository https://gitbox.apache.org/repos/asf/hadoop.git -r ba631c436b806728f8ec2f54ab1e289526c90579
Compiled by ztang on 2019-09-12T02:47Z
Compiled with protoc 2.5.0
From source with checksum ec785077c385118ac91aadde5ec9799
This command was run using /opt/module/hadoop-3.1.3/share/hadoop/common/hadoop-common-3.1.3.jar

5. 集群分发脚本xsync

需要对应用户名ssh可通

scp (secure copy) 实现服务器间copy数据

shell
scp -r <sourceFile> <targetfile>

# -r: 递归
# <source|target>: 格式 <user@><host>:<目录>/<文件>

rsync 用于备份和镜像,相较于scp,scp是复制所以文件,rsync复制差异文件

shell
rsync -ar <$pdir/$filename> <targetfile>

# -a: 归档拷贝
# -v: 显示过程
# <target>: 格式 <$user@><$host>:<$pdir>/<$fname>

如将hadoop复制到hadoop002rsync -av hadoop-3.1.3/ shadoop@hadoop002:/opt/module/hadoop-3.1.3/

编写脚本,${HOME}/bin目录下vim xsync

shell
#!/bin/bash
#1. 判断参数个数
if [ $# -lt 1 ]
then
    echo Not Enough Arguement!
    exit;
fi
#2. 遍历集群所有机器
for host in hadoop001 hadoop002 hadoop003
do
    echo ==================== $host ====================
    #3. 遍历所有目录,挨个发送
    for file in $@
    do
        #4. 判断文件是否存在
        if [ -e $file ]
        then
            #5. 获取父目录
            pdir=$(cd -P $(dirname $file); pwd)
            #6. 获取当前文件的名称
            fname=$(basename $file)
            ssh $host "mkdir -p $pdir"
            rsync -av $pdir/$fname $host:$pdir
        else
            echo $file does not exists!
        fi
    done
done

修改执行权限chmod +x xsync
测试脚本 ./xsync /home/shadoop/bin/

将脚本复制到/bin/中,方便全局调用sudo cp xsync /bin/

前面已复制hadoop到其他服务器中,若没复制xsync /opt/module/hadoop-3.1.3
复制配置到其他服务器sudo /bin/xsync /etc/profile.d/my_env.sh
去其他服务器中,使配置生效source /etc/profile.d/my_env.sh

保证所有服务器都有hadoop环境

集群

集群规划

hadoop001hadoop002hadoop003
HDFS

NameNode

DataNode
DataNode

SecondaryNameNode

DataNode
YARNNodeManager

ResourceManager

NodeManager
NodeManager
  • NameNode 和 SecondaryNameNode 不要安装在同一台服务器
  • ResourceManager 也很消耗内存,不要和 NameNode、SecondaryNameNode 配置在 同一台机器上。

配置集群

配置文件目录$HADOOP_HOME/etc/hadoop

core-site.xml

xml
<configuration>
    <!-- 指定 NameNode 的地址 -->
    <property>
        <name>fs.defaultFS</name>
        <value>hdfs://hadoop001:8020</value>
    </property>
    <!-- 指定 hadoop 数据的存储目录 -->
    <property>
        <name>hadoop.tmp.dir</name>
        <value>/opt/module/hadoop-3.1.3/data</value>
    </property>
    <!-- 配置 HDFS 网页登录使用的静态用户为 admin -->
    <property>
        <name>hadoop.http.staticuser.user</name>
        <value>admin</value>
    </property>
</configuration>

hdfs-site.xml

xml
<configuration>
    <!-- nn web 端访问地址-->
    <property>
        <name>dfs.namenode.http-address</name>
        <value>hadoop001:9870</value>
    </property>
    <!-- 2nn web 端访问地址-->
    <property>
        <name>dfs.namenode.secondary.http-address</name>
        <value>hadoop003:9868</value>
    </property>
</configuration>

yarn-site.xml

xml
<configuration>
    <!-- 指定 MR 走 shuffle -->
    <property>
        <name>yarn.nodemanager.aux-services</name>
        <value>mapreduce_shuffle</value>
    </property>
    <!-- 指定 ResourceManager 的地址-->
    <property>
        <name>yarn.resourcemanager.hostname</name>
        <value>hadoop002</value>
    </property>
    <!-- 环境变量的继承 -->
    <property>
        <name>yarn.nodemanager.env-whitelist</name>
        <value>JAVA_HOME,HADOOP_COMMON_HOME,HADOOP_HDFS_HOME,HADOOP_CO
        NF_DIR,CLASSPATH_PREPEND_DISTCACHE,HADOOP_YARN_HOME,HADOOP_MAP
        RED_HOME</value>
    </property>
</configuration>

mapred-site.xml

xml
<configuration>
    <!-- 指定 MapReduce 程序运行在 Yarn 上 -->
    <property>
        <name>mapreduce.framework.name</name>
        <value>yarn</value>
    </property>
</configuration>

分发配置 xsync /opt/module/hadoop-3.1.3/etc/hadoop/

配置群起worksvim workers

shell
hadoop001
hadoop002
hadoop003

分发配置 xsync /opt/module/hadoop-3.1.3/etc/