Flink是一个框架和分布式处理引擎,用于对无界和有界数据流进行有状态计算。
Flink安装前准备工作:1、使用xftp将Flink安装包上传到虚拟机中
flink-1.10.0-bin-scala_2.11.tgz
可以去国内镜像下载,也可以去apache 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可视化页面。
欢迎分享,转载请注明来源:内存溢出
评论列表(0条)