[系统运维] Flink 原生 Kubernetes 集成

开发: C++知识库 Java知识库 JavaScript Python PHP知识库人工智能区块链大数据移动开发嵌入式开发工具数据结构与算法开发测试游戏开发网络协议系统运维
教程: HTML教程 CSS教程 JavaScript教程 Go语言教程 JQuery教程 VUE教程 VUE3教程 Bootstrap教程 SQL数据库教程 C语言教程 C++教程 Java教程 Python教程 Python3教程 C#教程
数码: 电脑笔记本显卡显示器固态硬盘硬盘耳机手机 iphone vivo oppo 小米华为单反装机图拉丁

-> 系统运维 -> Flink 原生 Kubernetes 集成 -> 正文阅读

[系统运维]Flink 原生 Kubernetes 集成

0、准备工作

官网：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

1、创建角色

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

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

2、启动flink

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暴露一个端口的方式，然后访问端口就行
在这里插入图片描述