目录
1.环境版本
1.1 jdk
1.2.maven
1.3.node
1.4.scala
2.下载flink源码
3.编译源码
4.idea打开flink源码
5.运行wordcount
1.环境版本
软件地址
链接:https://pan.baidu.com/s/1ZxYydR8rBfpLCcIdaOzxVg
提取码:12xq
1.1 jdk
1.2 maven
1.3 node
node 编译 flink-runtime-web需要
1.4scala
(idea需要下载支持的scala插件)
以上环境需要在操作系统下配置环境遍历;
2.下载flink源码
点击下方连接
Apache Flink® — Stateful Computations over Data Streams | Apache Flink
打开如下页面,点击Downloads
点击带sources的模块
点击连接即可完成下载
下载之后解压
3.编译源码
进入flink1.17.1目录输入cmd
输入以下命令:
mvn clean install -DskipTests -Dfast
等待最终编译完成:
4.idea打开flink源码
flile->open->选择源码所在目录
5.运行wordcount
最终效果如下,如有出现依赖应