大家好,欢迎来到IT知识分享网。
本篇文章主要介绍flink的部署
一、部署
1、下载安装flink安装包 这里用的是1.15.1版本,下载地址:
https://www.apache.org/dyn/closer.lua/flink/flink-1.15.1/flink-1.15.1-bin-scala_2.12.tgz
2、解压安装包
tar -zxvf flink-1.15.1-bin-scala_2.12.tgz
3、启动flink集群
cd flink-1.15.1 & ./bin/start-cluster.sh
启动成功会显示日志如下:
Starting cluster.
Starting standalonesession daemon on host macBook-Pro-2.local.
Starting taskexecutor daemon on host macBook-Pro-2.local.
IT知识分享网
3、访问管理界面
localhost:8081
4、测试使用
根据提供的案例里词频统计 ,执行如下命令:
IT知识分享网./bin/flink run ./examples/batch/WordCount.jar
在completed jobs就能看到一条执行记录
整体的执行经过过程如下:
4、停止集群
./bin/stop-cluster.sh
免责声明:本站所有文章内容,图片,视频等均是来源于用户投稿和互联网及文摘转载整编而成,不代表本站观点,不承担相关法律责任。其著作权各归其原作者或其出版社所有。如发现本站有涉嫌抄袭侵权/违法违规的内容,侵犯到您的权益,请在线联系站长,一经查实,本站将立刻删除。 本文来自网络,若有侵权,请联系删除,如若转载,请注明出处:https://yundeesoft.com/6287.html