一:安装

Flink官网下载地址:https://flink.apache.org/downloads.html

选择1.6.3版本

Flink安装极简教程-单机版-LMLPHP

下载:

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.-bin-hadoop26-scala_2..tgz
mv flink-1.6. flink

查看本机host

Flink安装极简教程-单机版-LMLPHP

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

vim  conf/flink-conf.yaml

Flink安装极简教程-单机版-LMLPHP

修改conf/masters文件,修改后内容如下:

Flink安装极简教程-单机版-LMLPHP

启动单机版flink:

bin/start-cluster.sh

启动界面如下:

Flink安装极简教程-单机版-LMLPHP

查看启动是否成功:

Flink安装极简教程-单机版-LMLPHP

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

Flink安装极简教程-单机版-LMLPHP

二:官方案例演示

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

nc -lk 

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

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

Flink安装极简教程-单机版-LMLPHP

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

Flink安装极简教程-单机版-LMLPHP

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

Flink安装极简教程-单机版-LMLPHP

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

Flink安装极简教程-单机版-LMLPHP

Flink安装极简教程-单机版-LMLPHP

05-11 13:31