目录

目录

1.1软件安装

1.1.1 jdk

1.1.2 maven

1.1.3 node js

1.2 下载flink源码

1.3 编译源码

1.4 idea打开flink源码

1.5 运行wordcount

---

---

1.1软件安装

软件地址

链接：https://pan.baidu.com/s/1ZxYydR8rBfpLCcIdaOzxVg 
提取码：12xq

1.1.1 jdk

1.1.2 maven

 1.1.3 node js

node 编译 flink-runtime-web需要

 1.1.4 scala版本（idea需要下载支持的scala插件）

 以上环境需要在操作系统下配置环境遍历；

1.2 下载flink源码

点击下方连接

Apache Flink® — Stateful Computations over Data Streams | Apache Flink

打开如下页面，点击Downloads

点击带sources的模块

点击连接即可完成下载

 下载之后解压

 1.3 编译源码

进入flink1.17.1目录输入cmd

 

 输入以下命令：

mvn clean install -DskipTests -Dfast

等待最终编译完成：

1.4 idea打开flink源码

flile->open->选择源码所在目录 

1.5 运行wordcount

最终效果如下，如有出现依赖应