是一个商用Flink sql平台,基于k8s部署

一、安装
提前安装好docker、k8s、kubectl、helm
git clone --branch release-2.3 https://github.com/ververica/ververica-platform-playground.git cd ververica-platform-playground/ ./setup.sh --edition community # 安装社区版 kubectl get pods #安装好后会发现多了vvp namespace,且有minIO、platform窗口 kubectl --namespace vvp port-forward services/vvp-ververica-platform 8080:80 # 将容器里页面80端口转发到本地8080
二、使用
1、即席查询
执行查询前要建session cluster,flink容器指定到新的namespace vvp-jobs。然后所有的sql查询到这个session cluster执行

2、jar任务
上传jar包或使用网络jar包,配置独立的基于k8s的flink窗口。也支持升级任务,会自动使用保存点进行安全升级