下面以 CentOS 7/8 + Hadoop HDFS HA(基于 QJM) 为例,说明 HDFS 高可用(High Availability) 的配置步骤。这是生产环境最常用的方式。
角色说明:
Client
|
NameNode(Active) <---> NameNode(Standby)
| |
JournalNode x3
|
ZooKeeper x3
nn1: 192.168.1.11
nn2: 192.168.1.12
jn1: 192.168.1.13
jn2: 192.168.1.14
jn3: 192.168.1.15
dn1: 192.168.1.16
zk1: 192.168.1.17
zk2: 192.168.1.18
zk3: 192.168.1.19
# 关闭防火墙
systemctl stop firewalld
systemctl disable firewalld
# 关闭 SELinux
setenforce 0
sed -i 's/SELINUX=enforcing/SELINUX=disabled/' /etc/selinux/config
# 配置 hosts
cat >> /etc/hosts <<EOF
192.168.1.11 nn1
192.168.1.12 nn2
192.168.1.13 jn1
192.168.1.14 jn2
192.168.1.15 jn3
EOF
# 配置 SSH 免密(NN 之间必须)
ssh-keygen -t rsa
ssh-copy-id nn1
ssh-copy-id nn2
wget https://archive.apache.org/dist/zookeeper/zookeeper-3.7.1/apache-zookeeper-3.7.1-bin.tar.gz
tar -zxvf apache-zookeeper-3.7.1-bin.tar.gz -C /opt
tickTime=2000
dataDir=/data/zookeeper
clientPort=2181
server.1=zk1:2888:3888
server.2=zk2:2888:3888
server.3=zk3:2888:3888
echo 1 > /data/zookeeper/myid # zk1
# zk2 -> 2, zk3 -> 3
<configuration>
<property>
<name>fs.defaultFS</name>
<value>hdfs://mycluster</value>
</property>
<property>
<name>ha.zookeeper.quorum</name>
<value>zk1:2181,zk2:2181,zk3:2181</value>
</property>
</configuration>
<configuration>
<!-- 名称服务 -->
<property>
<name>dfs.nameservices</name>
<value>mycluster</value>
</property>
<property>
<name>dfs.ha.namenodes.mycluster</name>
<value>nn1,nn2</value>
</property>
<!-- NameNode RPC -->
<property>
<name>dfs.namenode.rpc-address.mycluster.nn1</name>
<value>nn1:8020</value>
</property>
<property>
<name>dfs.namenode.rpc-address.mycluster.nn2</name>
<value>nn2:8020</value>
</property>
<!-- HTTP -->
<property>
<name>dfs.namenode.http-address.mycluster.nn1</name>
<value>nn1:9870</value>
</property>
<property>
<name>dfs.namenode.http-address.mycluster.nn2</name>
<value>nn2:9870</value>
</property>
<!-- JournalNode -->
<property>
<name>dfs.namenode.shared.edits.dir</name>
<value>qjournal://jn1:8485;jn2:8485;jn3:8485/mycluster</value>
</property>
<property>
<name>dfs.journalnode.edits.dir</name>
<value>/data/journalnode</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>/root/.ssh/id_rsa</value>
</property>
<!-- 自动故障转移 -->
<property>
<name>dfs.ha.automatic-failover.enabled</name>
<value>true</value>
</property>
</configuration>
zkServer.sh start
hdfs --daemon start journalnode
# 在 nn1
hdfs namenode -format
hdfs zkfc -formatZK
# 在 nn2
hdfs namenode -bootstrapStandby
hdfs --daemon start namenode
hdfs --daemon start zkfc
hdfs --daemon start datanode
hdfs haadmin -getServiceState nn1
hdfs haadmin -getServiceState nn2
手动测试:
hdfs haadmin -failover nn1 nn2
/data/journalnode 重新初始化ssh nn2 免密可用如果你需要 CentOS + Hadoop 3.x 具体版本 YAML/脚本 或 非 QJM(NFS)方式,可以继续问我。