Flink on K8s部署

1.安装K8S

参考上篇博客K8S原理、安装和部署

2.安装Helm并加入环境变量

Helm可以帮忙管理k8s的应用,用它来安装minio和vvp,如果下载很慢,可以根据官网选择其他安装方式

wget https://get.helm.sh/helm-v3.5.4-linux-amd64.tar.gz
tar -xvzf helm-v3.5.4-linux-amd64.tar.gz
mv linux-amd64/helm helm

#添加环境变量
vim ~/.bashrc
export HELM_HOME=/opt
export PATH=$PATH:$HELM_HOME
source ~/.bashrc

 

3.设置组件

首先到ververica-platform-playground目录下输入./setup.sh --edition community就可以完成以下所有步骤,如果成功,可以看到以下信息

Flink on K8s部署

看一下pod情况,注意看一下ready和status是否正确,如果ready那里是2/3或者status是pending,就说明pod有异常。

Flink on K8s部署

如果不成功,就一步步安装

3.1创建命名空间

kubectl create namespace vvp
kubectl create namespace vvp-jobs

3.2安装MinIO

helm repo add stable https://charts.helm.sh/stable

helm --namespace vvp install minio stable/minio --values values-minio.yaml 
如果遇到报错Error: failed post-install: timed out waiting for the condition 就加上上面的--timeout 30m,不然会超时报错

3.3安装ververica plateform

helm repo add ververica https://charts.ververica.com

helm --namespace vvp install ververica/ververica-platform --values values-vvp.yaml --set acceptCommunityEditionLicense=true

如果要开启网页访问 kubectl --namespace vvp port-forward services/vvp-ververica-platform 8080:80 然后到 http://localhost:8080就可以访问了

或者K8s官网kubectl get pod vvp-ververica-platform-77c9d7fcf5-kv49g -n vvp  --template='{{(index (index .spec.containers 0).ports 0).containerPort}}{{"\n"}}'

4.删除安装

如果要撤销helm部署的应用和删除创建的空间,运行./teardown.sh就行了

手工删除pods要先删除部署,不然会自愈 kubectl delete deployment <minio> -n vvp         <>里面是任务名

然后kubectl delete pods <minio-54d665fbd5-zq5jv> --grace-period=0 --force -n vvp         <>里面是pod名称

 

5.报错信息:

在安装过程中可能遇到各种报错,比如

deployment.apps/minio condition met
error: timed out waiting for the condition on deployments/vvp-ververica-platform

可以看看pod的event用kubectl describe po -n vvp 看到报错信息 是cpu不够或者内存不够

default-scheduler  0/1 nodes are available: 1 Insufficient cpu.

根据自己电脑情况调整一下资源请求就好了

Flink on K8s部署

 

上一篇:NolanJdc2.3若兰更新教程 对接XDD—PLUS(1月7日更新)


下一篇:青龙面板&xdd-plus&傻妞sillyGirl&nvjdc保姆级安装系列教程