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可视化页面。

在这里插入图片描述

Logo

华为开发者空间,是为全球开发者打造的专属开发空间,汇聚了华为优质开发资源及工具,致力于让每一位开发者拥有一台云主机,基于华为根生态开发、创新。

更多推荐