Flink下载

1.1、登陆Flink官网

1.2、进入下载页面

下载最新版本，当前（2021年12月11日）版本是1.14.0

1.3、Flink版本说明：

前面蓝色部分是flink版本，后面绿色部分是scala版本

Apache Flink 1.14.0 for Scala 2.11

Apache Flink 1.14.0 Source Release，这个是Apache Flink源码

1.4、windows版本支持

Flink1.14.0版本不支持windows环境安装

Flink1.13.3版本不支持windows环境安装

Flink1.8版本支持windows环境安装

其它版本下载后，查看下bin目录下有没有.bat执行文件，即可确认是否支持windows版本。

虚拟机安装配置

为了安装Flink1.14.0版本，首先安装虚拟机，在虚拟机上面安装Flink。

虚拟机网络配置好后，可以通过浏览器直接下载安装包。

JDK安装配置

JDK版本要求：JDK8，JDK11

3.1、下载JDK：

示例中使用的是JDK8

wget --no-check-certificate --no-cookies --header "Cookie: oraclelicense=accept-securebackup-cookie" http://download.oracle.com/otn-pub/java/jdk/8u131-b11/d54c1d3a095b4ff2b6607d096fa80163/jdk-8u131-linux-x64.tar.gz

3.2、解压JDK1.8压缩包

tar -zxvf jdk-8u131-linux-x64.tar.gz

3.3、环境变量配置

编辑/etc/profile文件，在文件尾部增加以下内容

export JAVA_HOME=/home/flink/jdk1.8.0_131
export JRE_HOME=${JAVA_HOME}/jre
export CLASSPATH=.:${JAVA_HOME}/lib:${JRE_HOME}/lib:$CLASSPATH
export JAVA_PATH=${JAVA_HOME}/bin:${JRE_HOME}/bin
export PATH=$PATH:${JAVA_PATH}

执行 source /etc/profile，让环境变量立即生效

Flink安装

4.1、Flink下载

wget https://dlcdn.apache.org/flink/flink-1.14.0/flink-1.14.0-bin-scala_2.11.tgz

4.2、Flink安装包解压

tar -zxvf flink-1.14.0-bin-scala_2.12.tgz

4.3、启动Flink

cd /home/flink/flink-1.14.0/bin
./start-cluster.sh

4.4、停止Flink

cd /home/flink/flink-1.14.0/bin
./stop-cluster.sh

提交作业

examples目录下有示例作业

//运行以下命令，提交WordCount作业
./bin/flink run examples/streaming/WordCount.jar

//查看作业运行结果
tail log/flink-*-taskexecutor-*.out

Web UI监控作业运行状况

http://localhost:8081

至此，Flink学习环境配置成功。