环境要求

要求 版本 是否必须 其他事项
操作系统 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源码

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

构建项目

  1. cd incubator-streampark/
  2. ./build.sh

打开项目

此处使用idea打开项目

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

解压缩包

  1. cd ./dist
  2. 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

修改启动配置

Streampark Modify Run Configuration

勾选 Add VM options 和 Add dependencies with "provided" scope to classpath，填写参数 -Dapp.home=$path，$path 是我们刚刚复制的路径

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

Streampark Run Config

然后启动后台服务即可

启动前端服务

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

Streampark Frontend Running

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

Streampark Select Team

演示调试代码

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

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

Streampark Project Build

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

Streampark Project Build