大家好,欢迎来到IT知识分享网。
一.下载
https://flink.apache.org/downloads.html
二.解压
tar -zxvf flink-1.12.4-bin-scala_2.11.tgz
三.配置环境变量
vi /etc/profile
在末尾填上
export FLNK_HOME=/home/flink-1.12.4
export PATH=$FLINK_HOME/bin:$PATH
四.启动Flink
cd /home/flink-1.12.4/bin
./start-cluster.sh
启动后使用jps,可以看到TaskManagerRunner,StandaloneSessionClusterEntrypoint
五.访问Web界面
http://http://192.168.1.11:8081
六.简单例子测试
cd /home/flink-1.12.4/examples/batch
/home/flink-1.12.4/bin/flink run WordCount.jar
免责声明:本站所有文章内容,图片,视频等均是来源于用户投稿和互联网及文摘转载整编而成,不代表本站观点,不承担相关法律责任。其著作权各归其原作者或其出版社所有。如发现本站有涉嫌抄袭侵权/违法违规的内容,侵犯到您的权益,请在线联系站长,一经查实,本站将立刻删除。 本文来自网络,若有侵权,请联系删除,如若转载,请注明出处:https://yundeesoft.com/12135.html