Flink安装极简教程

Posted 2021-04-13 码农code之路

一：安装

Flink被称为第 4 代大数据计算引擎，前段时间阿里开源了Blink，又把Flink推上了新的高度。

选择1.6.3版本

下载：

wget http://mirrors.hust.edu.cn/apache/flink/flink-1.7.1/flink-1.7.1-bin-hadoop26-scala_2.11.tgz

解压：

tar -zxvf flink-1.6.3-bin-hadoop26-scala_2.11.tgz
mv  flink-1.6.3 flink

查看本机host

进入flink目录，修改conf/flink-conf.yaml文件

vim  conf/flink-conf.yaml

修改conf/masters文件，修改后内容如下：

启动单机版flink：

bin/start-cluster.sh

启动界面如下：

查看启动是否成功：

查看dashboard界面:http://192.168.186.129:8081

二：官方案例演示

1.启动一个终端输入如下指令：

nc -lk 8000

2.启动第二个终端，执行flink自带的wordcount案例

bin/flink run examples/streaming/SocketWindowWordCount.jar --port 8000

3.在第一个终端发送数据：

4.测试结果保存在log/flink-root-taskexecutor-0-woniu.out文件中

5. Dashboard也可以看到任务信息

往期推荐：