废话不多说，直接开始。
第一步：先查看hadoop版本和scala版本。
hadoop版本如下：
Hadoop版本
Scala版本
第二步：去官网找对应的flink版本（下载地址：{+}http://flink.apache.org/downloads.html+。）
第三步：将下载的组件上传到服务器指定的位置:/opt/cloudera/parcels/CDH/lib
第四步：在192.168.201.83（主节点centos4上配置相关参数）
4.1配置conf/flink-conf.yaml
# 设置jobmanager.rpc.address 配置项为该节点的IP 或者主机名
4.2配置conf/slaves
第五步：将主节点配置好的flink发送到从节点（centos5，centos6）
命令如下：
scp -r flink-1.7.2 root@192.168.201.84:/opt/cloudera/parcels/CDH/lib
scp -r flink-1.7.2 root@192.168.201.85:/opt/cloudera/parcels/CDH/lib
第六步：启动flink
第七步：指定JobManger的可视化端口，尽量配置一个不容易冲突的端口（默认是8081和spark冲突故改为5566）
浏览器输入：192.168.201.83:5566 如下：
网友评论