0


1.Flink源码编译

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

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

标签: flink 大数据

本文转载自: https://blog.csdn.net/lw277232240/article/details/132433237
版权归原作者 键盘上的艺术家w 所有, 如有侵权,请联系我们删除。

“1.Flink源码编译”的评论:

还没有评论