一:下载安装(前提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