开发指南

环境要求

要求	版本	是否必须	其他事项
操作系统	Linux		支持 Windows, 推荐使用 Mac/Linux.
IDE	Intellij IDEA		推荐使用 Intellij IDEA
JAVA	1.8 +
Scala	2.12.x		如果 IDE 是 Intellij IDEA 直接安装Scala插件即可
Nodejs	16.14.x ~ 18		https://nodejs.org
pnpm	7.11.2		npm install -g pnpm
Flink	1.12.0 +		Flink >= 1.12, 只需要从Flink官网下载解绑即可
MySQL	5.6 +
Hadoop	2 +		可选,如果部署flink on yarn 需要配置hadoop环境变量.

clone源码

git clone https://github.com/apache/incubator-streampark.git

构建项目

cd incubator-streampark/
./build.sh

打开项目

此处使用idea打开项目

open -a /Applications/IntelliJ\ IDEA\ CE.app/ ./

解压缩包

cd ./dist
tar -zxvf apache-streampark-2.2.0-incubating-bin.tar.gz

复制路径

复制解压后的目录路径，例：${workspace}/incubator-streampark/dist/apache-streampark-2.2.0-incubating-bin

启动后台服务

找到 streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/StreamParkConsoleBootstrap.java

修改启动配置

勾选Add VM options，填写参数-Dapp.home=$path，$path是我们刚刚复制的路径

-Dapp.home=${workspace}/incubator-streampark/dist/apache-streampark-2.2.0-incubating-bin

然后启动后台服务即可

启动前端服务

cd ../streampark-console/streampark-console-webapp
pnpm serve

访问 http://localhost:10001/ ，输入用户名admin密码streampark，选择一个team进入

演示调试代码

1.在idea以debug模式启动项目

2.在ApplicationController的flink/app/list加入断点

3.输入帐号密码登陆streampark,选择team之后就会触犯断点