1 概述：Flink 安装部署篇
1.0 前置知识
1.0.1 Flink 概述
- Apache Flink 概述 - 博客园/千千寰宇
1.0.2 Flink Demo Job
- Flink Demo Job : WordCount - 博客园/千千寰宇
1.1 Windows下安装 Flink 1.9.3
Step0 版本规划
-
未来欲使用Flink CDC必须使用Flink 1.12+、JDK1.8+；但支持Windows端运行的，目前仅Flink 1.9.x支持
-
Flink：
- Flink
- https://github.com/apache/flink
- Flink CDC
- https://github.com/ververica/flink-cdc-connectors
- Flink 第三方社区
- https://flink-learning.org.cn/
Step1 安装 JDK1.8（略）
- 验证安装情况
java -version
注：涉及对2个系统变量的配置：
JAVA_HOME/PATH
- 推荐文献
- [Java/Linux] Java JDK 的安装与卸载: CentOS 7 / Ubuntu 22 / Windows - 博客园/千千寰宇
Step2 下载并解压Flink安装包
- 下载链接
- https://archive.apache.org/dist/flink/flink-1.14.2/flink-1.14.2-bin-scala_2.12.tgz
- https://archive.apache.org/dist/flink/flink-1.15.0/flink-1.15.0-bin-scala_2.12.tgz
- 或 https://dlcdn.apache.org/flink/flink-1.15.0/flink-1.15.0-bin-scala_2.12.tgz
- 如果需要其他版本，可以在如下链接下载：
- 下载： https://archive.apache.org/dist/flink/
- 或 https://www.apache.org/dyn/closer.lua/flink/
- https://dlcdn.apache.org/flink/
- https://dlcdn.apache.org/flink/flink-1.15.0/
- https://dlcdn.apache.org/flink/flink-1.15.0/flink-1.15.0-bin-scala_2.12.tgz
- 解压到：
D:\Program_Files\Flink\flink-1.15.0
Step3 配置系统变量 FLINK_HOME / PATH [可选步骤]
- PATH
%FLINK_HOME%\bin\
Step4 运行 Flink Job
- 运行Flink的命令非常简单，只需要进入到解压目录的bin目录下，运行如下脚本即可。
D:
cd %FLINK_HOME%
.\bin\start-cluster.bat
- 小思考题：为什么要用管理员权限运行呢？
Step5 功能测验
- 推荐文献
- [Flink] Flink Job之Web UI - 博客园/千千寰宇
Step5.1 Flink WEB-UI
Flink有个 UI 界面，可以用于监控Flilnk的job运行状态，已给出了具体链接。↓
http://localhost:8081/
Step5.2 运行Flink WordCount App/Job
- 运行自带的 WordCount 示例程序：
D: cd %FLINK_HOME% bin\flink.bat run examples\batch\WordCount.jar -input %FLINK_HOME%\README.txt -output %FLINK_HOME%\README_CountWord_Result.txt
Step5.3 查看运行状态和运行结果
- Flink WEB-UI
- 结果文件
Y 推荐文献
- Apache Flink 概述 - 博客园/千千寰宇
- Apache Stream Park : 一站式的流处理计算开发运管平台 - 博客园/千千寰宇
X 参考文献
- Flink基础系列3-windows安装Flink – CSDN
