下载

下载之前查看自己的hadoop版本

！！！下载的flink的版本一定要和hadoop的版本匹配
下载地址： http://www.apache.org/dyn/closer.lua/flink/flink-1.4.0/flink-1.4.0-bin-hadoop28-scala_2.11.tgz

解压缩时遇到问题

通过查找是因为下载的是一个页面，大小很小；而不是需要的压缩文件。
进入网页后找到下载网址：https://archive.apache.org/dist/flink/flink-1.4.0/flink-1.4.0-bin-hadoop28-scala_2.11.tgz

安装了两个

解压、安装以及配置环境变量

sudo tar zxvf flink-1.4.0-bin-hadoop28-scala_2.11.tgz.1 -C ./

得到解压后的文件

进入conf配置文件目录下，主要配置文件为flink-conf.yaml和slaves,配置flink-conf.yaml解析如下：

启动

首先,我们可以通过netcat命令来启动本地服务:

提交Flink程序，这里运行的是flink自带的example:

应用程序连接socket并等待输入，你可以通过web界面来验证任务期望的运行结果：

点击running