Flink 原生 Kubernetes 集成

官网：https://nightlies.apache.org/flink/flink-docs-release-1.14/zh/docs/deployment/ha/kubernetes_ha/

1）flink安装包（我用的1.13）

2）kubernetes 环境 我的版本是 1.20.4 、kubesphere3.1.1

3）服务器上装好jdk1.8

kubectl create serviceaccount flink-service-account
kubectl create clusterrolebinding flink-role-binding-flink --clusterrole=edit --serviceaccount=default:flink-service-account

flink 会动态的创建taskmanager 的容器，需要创建具有RBAC权限角色去创建删除容器

1）解压缩 tar -zxvf xxxx 就会看到bin目录下的kubernetes-session.sh脚本

2) 启动命令

#需要注意:
#1、要用创建好的角色去启动
#2、taskmanager的内存、cpu根据自己的情况来，自动创建taskmanager 出现pending 就是因为内存 cpu 之内的不够

bin/kubernetes-session.sh 
-Dkubernetes.cluster-id=kube-flink-01 -Dtaskmanager.memory.process.size=1024m -Dkubernetes.taskmanager.cpu=0.3 -Dtaskmanager.numberOfTaskSlots=2  
-Dkubernetes.service-account=flink-service-account

3）改flink服务的外网访问方式，我是用kubesphere 改成了nodepoint暴露一个端口的方式，然后访问端口就行

4）设置flink的存储挂载,还没懂flink的那些文件需要挂载，现在这样学习就够用了，以后再更新，实际上原生的standalone模式也够用了