Flink简述:
Flink是一个框架和分布式处理引擎,用于对无界和有界数据流进行有状态计算。
Flink安装前准备工作:
1、使用xftp将Flink安装包上传到虚拟机中
flink-1.10.0-bin-scala_2.11.tgz
可以去国内镜像下载,也可以去apache flink官网下载
Flink安装操作步骤:
1、解压缩文件
tar -zxf flink-1.10.0-bin-scala_2.11.tgz -C ../soft/
2、为了方便以后使用,将解压缩后的文件夹修改名字
mv flink-1.10.0/ flink
3、选择性配置环境变量
vim /etc/profile
#FLINK_HOME
export FLINK_HOME=/opt/soft/flink
export PATH=$PATH:$FLINK_HOME/bin
4、进入flink的conf目录下,修改配置文件
vim flink-conf.yaml
(已注明行号)
33 jobmanager.rpc.address: node1
5、修改conf/slaves,将集群中的另外两台添加进去
node2
node3
6、分发文件到集群
xsync flink/
xsync /etc/profile
7、启动flink
进入到flink的bin目录下,
cd /opt/soft/flink/bin
命令:
./start-cluster.sh
打开浏览器,输入node1:8081 即可看到flink的web可视化页面。
版权归原作者 万家林 所有, 如有侵权,请联系我们删除。