跳到主要内容

快速入门

如果要快速入门 StreamPark，可以 一键安装部署 或者 手动安装部署 。

1.一键安装​

如果需要一键安装 StreamPark，直接复制如下命令即可：

curl -L https://streampark.apache.org/quickstart.sh | sh

如果提示如下内容，表示安装部署成功： one_key_install

备注

脚本已经帮我们安装好 StreamPark 以及 Flink 集群了，直接登录即可启动作业

登录系统后，点击启动即可启动默认作业。

登录地址：http://127.0.0.1:8081 ，登录账号密码：admin / streampark): job_start_success

2. 手动安装​

只需按照以下三个步骤，即可快速入门StreamPark：

  • Step1：环境准备
  • Step2：StreamPark 安装
  • Step3：部署作业

2.1 环境准备​

物料版本要求演示版本（仅供参考）
操作系统Linux/MacOSMacOS
JavaJDK version >=1.181.8.0_362
ScalaScala version >=2.122.12.18
FlinkFlink version >= 1.121.19.0
StreamPark安装包任意版本2.1.5

备注：默认用户在本地已经安装好 JDK 以及 Scala 环境。

2.2 StreamPark 安装​

首先从官网直接下载最新版的 StreamPark，本文使用的是 2.1.5 版本 ，下载地址：https://streampark.apache.org/download

下载完成后，解压到本地的某个目录，进入 bin 目录启动 StreamPark ，相关脚本如下：

# 解压StreamPark安装包.
tar -zxvf apache-streampark_2.12-2.1.5-incubating-bin.tar.gz

# 启动StreamPark.
cd apache-streampark_2.12-2.1.5-incubating-bin/bin
./startup.sh

启动成功后界面如下： startup-success

登录 StreamPark，地址：http://127.0.0.1:10000

提示

账号密码为：admin/streampark

login-page

2.3 部署作业​

首次登录系统后，会发现已经有一个默认创建好的 FlinkSQL 作业。为了更好地演示，这里使用 Standalone 模式来运行这个作业。在此之前，需要先配置 Flink 版本与关联 Flink 集群。

注意

Flink 安装包需要与 StreamPark 服务同在一台服务器。

首先需要配置 Flink 版本，即指定本地 Flink 的解压路径。依次点击：设置中心 → Flink 版本 → 新建

flink_home

2.3.2 配置Flink集群​

备注

需要确保本地的 Flink 集群已经启动（直接进入 Flink 解压目录下的bin目录，执行./start-cluster.sh即可）

关联Flink集群，依次点击：设置中心 → Flink集群 → 添加 flink_cluster

2.3.3 配置作业​

点击作业配置，进入作业配置页面： job_config

只需要修改部署模式、Flink 版本、Flink 集群，保存即可： job_config_detail

点击上线： job_release

启动作业： job_start

启动成功后的页面如下： job_start_success

当然也能进入详情页面查看作业详情： job_detail

这里不再演示其它的功能，值得您继续探索...

3. 可能会遇到的问题​

如果遇到如下错误：

注意

ERROR: streampark.workspace.local: "/tmp/streampark" is an invalid path, please reconfigure in ...

可以考虑直接在系统的 /tmp 目录创建 streampark 文件夹或在安装目录下的 /conf/config.yaml 文件里配置 streampark.workspace.local 属性为一个合法的临时目录路径。