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/bin4、进入flink的conf目录下,修改配置文件vim flink-conf.yaml(已注明行号)
33 jobmanager.rpc.address: node15、修改conf/slaves,将集群中的另外两台添加进去
node2 node36、分发文件到集群
xsync flink/ xsync /etc/profile7、启动flink 进入到flink的bin目录下,cd /opt/soft/flink/bin 命令:./start-cluster.sh
打开浏览器,输入node1:8081 即可看到flink的web可视化页面。
1.本站遵循行业规范,任何转载的稿件都会明确标注作者和来源;2.本站的原创文章,会注明原创字样,如未注明都非原创,如有侵权请联系删除!;3.作者投稿可能会经我们编辑修改或补充;4.本站不提供任何储存功能只提供收集或者投稿人的网盘链接。 |