Linux安装Flink
1、下载
flink有两个版本,一个版本是和hadoop捆绑的,另一个是单独的,我们以单独的为例:
flink-1.9.3-bin-scala_2.11.tgz
2、解压
tar -zxvf flink-1.9.3-bin-scala_2.11.tgz -C /opt/
解压到/opt/目录下
3、配置环境变量
打开配置文件:
vi /etc/profile
配置内容如下:
# Flink
export FLINK_HOME=/opt/flink-1.9.3
export PATH=$FLINK_HOME/bin:$PATH
保存配置:
source /etc/profile
4、启动Flink
执行
start-cluster.sh
jps查看是否启动成功:
5、查看管理页面
6、运行一个example
(1)打开第一个窗口:
监听8888端口:
nc -lk 8888
如果没有安装nc,执行如下命令安装:
yum install -y nc
(2)打开第二个窗口
进入flink安装目录,启动单词统计的java程序 SocketWindowWordCount,并监听8888端口
flink run examples/streaming/SocketWindowWordCount.jar --port 8888
(3)打开第三个窗口
进入flink安装目录下的log目录,查看统计结果:
tail -f flink-root-taskexecutor-0-bigdata111.out