一：下载安装（前提jdk安装成功）
版本选择：1.7.2，不集成其它组件。
下载网址：https://flink.apache.org/downloads.html
格式：flink-1.7.2-bin-scala_2.11.tgz
解压缩：tar -zxvf flink-1.7.2-bin-scala_2.11.tgz
配置环境变量：cd ~
vim .bash_profile
export FLINK_HOME=/home/alex/soft/flink
export PATH=$FLINK_HOME/bin:$PATH
export PATH
source .bash_profile
二：提交任务
启动flink：./bin/start-cluster.sh
查看WebUi：ip:8081，端口默认为8081
提交任务（socketwordcount）简单测试：
说明：基于流式的单词统计
1.启动9999端口
nc -l 9999
2.提交任务
flink run examples/streaming/SocketwindowWordCount.jar --port 9999
版权声明：本文内容由互联网用户自发贡献，该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容， 请发送邮件至 [email protected] 举报，一经查实，本站将立刻删除。
