Ververica Platform流平台搭建使用

是一個商用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、即席查詢

https://docs.ververica.com/getting_started/sql_development.html

執行查詢前要建session cluster，flink容器指定到新的namespace vvp-jobs。然后所有的sql查詢到這個session cluster執行

2、jar任務

https://docs.ververica.com/getting_started/flink_operations.html

上傳jar包或使用網絡jar包，配置獨立的基於k8s的flink窗口。也支持升級任務，會自動使用保存點進行安全升級