10、Flink高可用HA

先搭建zookeeper

上传zookeeper并解压

把没有用的删除

 创建一个目录zkData

修改zookeeper的配置文件

dataDir=/opt/modules/apache-zookeeper-3.6.1-bin/zkData

server.1=master:2888:3888
server.2=slave1:2888:3888
server.3=slave2:2888:3888

创建myid文件

 在里面输入1

现在我们对zookeeper的配置就完成了，接下来就是分发给另外两台机器。

scp -r apache-zookeeper-3.6.1-bin/ hadoop@slave1:/opt/modules/

 scp -r apache-zookeeper-3.6.1-bin/ hadoop@slave2:/opt/modules/

分发完之后分别把/opt/modules/apache-zookeeper-3.6.1-bin/zkData 下的myid改成2和3

接下来启动zookeeper服务，在三台机器都要启动

启动完之后我们就可以通过客户端来连接我们的服务了

现在查看谁是“老大”

zookeeper部署完成！！

显然这里需要先部署hadoop的高可用

 先上传hadoop包，解压

修改配置文件

修改  hadoop-env.sh

export JAVA_HOME=/opt/modules/jdk1.8.0_221

修改  yarn-env.sh

export JAVA_HOME=/opt/modules/jdk1.8.0_221

 vim  mapred-env.sh 

export JAVA_HOME=/opt/modules/jdk1.8.0_221

修改hdfs-site.xml

<property>
        <name>dfs.nameservices</name>
        <value>ns</value>
    </property>
    
    <property>
        <name>dfs.ha.namenodes.ns</name>
        <value>nn1,nn2</value>
    </property>
    
    <property>
        <name>dfs.namenode.rpc-address.ns.nn1</name>
        <value>master:9000</value>
    </property>
    
    <property>
        <name>dfs.namenode.http-address.ns.nn1</name>
        <value>master:50070</value>
    </property>
    
    <property>
        <name>dfs.namenode.rpc-address.ns.nn2</name>
        <value>slave1:9000</value>
    </property>
    
    <property>
        <name>dfs.namenode.http-address.ns.nn2</name>
        <value>slave1:50070</value>
    </property>
    
    <property>
        <name>dfs.namenode.shared.edits.dir</name>
        <value>qjournal://master:8485;slave1:8485;slave2:8485/ns</value>
    </property>
    
    <property>
        <name>dfs.journalnode.edits.dir</name>
        <value>/opt/modules/hadoop-2.8.5/data/jn</value>
    </property>
    
    <property>
        <name>dfs.ha.automatic-failover.enabled</name>
        <value>true</value>
    </property>

    <property>
        <name>dfs.client.failover.proxy.provider.ns</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/hadoop/.ssh/id_rsa</value>
    </property>
    <property>
        <name>dfs.replication</name>
        <value>3</value>
    </property>
    <property>
        <name>dfs.permissions.enabled</name>
        <value>false</value>
    </property>

修改core-site.xml

<property>
        <name>fs.defaultFS</name>
        <value>hdfs://ns/</value>
    </property>
    
    <property>
        <name>hadoop.tmp.dir</name>
        <value>/opt/modules/hadoop-2.8.5/tmp</value>
    </property>
    
    <property>
        <name>ha.zookeeper.quorum</name>
        <value>master:2181,slave1:2181,slave2:2181</value>
    </property>

修改mapred-site.xml

mv mapred-site.xml.template mapred-site.xml

vim  mapred-site.xml

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

<property>
        <name>mapreduce.jobhistory.webapp.address</name>
        <value>master:19888</value>
    </property>

<property>
        <name>mapreduce.jobhistory.address</name>
        <value>master:10020</value> 
</property>

vim yarn-site.xml

<!-- 开启RM高可用 -->
    <property>
        <name>yarn.resourcemanager.ha.enabled</name>
        <value>true</value>
    </property>
    <!-- 指定RM的cluster id -->
    <property>
        <name>yarn.resourcemanager.cluster-id</name>
        <value>rs</value>
    </property>
    <!-- 指定RM的名字 -->
    <property>
        <name>yarn.resourcemanager.ha.rm-ids</name>
        <value>rm1,rm2</value>
    </property>
    <!-- 分别指定RM的地址 -->
    <property>
        <name>yarn.resourcemanager.hostname.rm1</name>
        <value>master</value>
    </property>
    <property>
        <name>yarn.resourcemanager.hostname.rm2</name>
        <value>slave1</value>
    </property>
    <!-- 指定zk集群地址 -->
    <property>
        <name>yarn.resourcemanager.zk-address</name>
        <value>master:2181,slave1:2181,slave2:2181</value>
    </property>
    <property>
        <name>yarn.nodemanager.aux-services</name>
        <value>mapreduce_shuffle</value>
    </property>

修改slaves

master
slave1
slave2

将配置好的hadoop分发给其他节点

scp -r hadoop-2.8.5/ hadoop@slave1:/opt/modules/

 scp -r hadoop-2.8.5/ hadoop@slave2:/opt/modules/

启动journalnode（在所有机器都启动）

./hadoop-daemon.sh start journalnode

格式化namenode

bin/hdfs namenode -format

如果出现这样的问题

 检查对应的机器的防火墙是否关闭

启动namenode

./hadoop-daemon.sh start namenode

在nn2上同步nn1的元数据信息

bin/hdfs  namenode  -bootstrapStandby

格式化ZKFC

bin/hdfs zkfc -formatZK

直接一键启动吧

配置flink的高可用

vim flink-conf.yaml

high-availability: zookeeper
high-availability.zookeeper.quorum: master:2181,slave1:2181,slave2:2181,
high-availability.zookeeper.path.root: /flink
high-availability.cluster-id: /cluster_one 
high-availability.storageDir: hdfs://ns/flink/recovery

同时把修改后的配置文件同步到另外两个节点

修改master文件

把master文件同步到另外两个节点去

在master节点

vim flink-conf.yaml

在slave1节点

vim flink-conf.yaml

配置hadoop环境变量，三个节点都配置

#hadoop
export HADOOP_HOME=/opt/modules/hadoop-2.8.5
export PATH=$HADOOP_HOME/bin:$PATH

启动flink集群

我们查看进程，发现并没有flink的进程

查看日志

这样解决

进入flink的官网​​https://flink.apache.org/downloads.html#all-stable-releases​​

根据自己的hadoop版本下载对应的架包

把架包上传到三个节点的flink/lib目录下

重新启动一下flink集群

分别查三个节点的进程

打开浏览器访问flink的主页