Subsections of On K8s Operator
Job Privilieges
Template
apiVersion: rbac.authorization.k8s.io/v1
kind: Role
metadata:
namespace: flink
name: flink-deployment-manager
rules:
- apiGroups:
- flink.apache.org
resources:
- flinkdeployments
verbs:
- 'get'
- 'list'
- 'create'
- 'update'
---
apiVersion: rbac.authorization.k8s.io/v1
kind: RoleBinding
metadata:
name: flink-deployment-manager-binding
namespace: flink
subjects:
- kind: User
name: "277293711358271379"
apiGroup: rbac.authorization.k8s.io
roleRef:
kind: Role
name: flink-deployment-manager
apiGroup: rbac.authorization.k8s.io
OSS Template
Template
apiVersion: "flink.apache.org/v1beta1"
kind: "FlinkDeployment"
metadata:
name: "financial-job"
spec:
image: "cr.registry.res.cloud.wuxi-yqgcy.cn/mirror/financial-topic:1.5-oss"
flinkVersion: "v1_17"
flinkConfiguration:
taskmanager.numberOfTaskSlots: "8"
fs.oss.endpoint: http://ay-test.oss-cn-jswx-xuelang-d01-a.ops.cloud.wuxi-yqgcy.cn/
fs.oss.accessKeyId: 4gqOVOfQqCsCUwaC
fs.oss.accessKeySecret: xxx
ingress:
template: "flink.k8s.io/{{namespace}}/{{name}}(/|$)(.*)"
className: "nginx"
annotations:
cert-manager.io/cluster-issuer: "self-signed-ca-issuer"
nginx.ingress.kubernetes.io/rewrite-target: "/$2"
serviceAccount: "flink"
podTemplate:
apiVersion: "v1"
kind: "Pod"
metadata:
name: "financial-job"
spec:
containers:
- name: "flink-main-container"
env:
- name: ENABLE_BUILT_IN_PLUGINS
value: flink-oss-fs-hadoop-1.17.2.jar
jobManager:
resource:
memory: "2048m"
cpu: 1
taskManager:
resource:
memory: "2048m"
cpu: 1
job:
jarURI: "local:///app/application.jar"
parallelism: 1
upgradeMode: "stateless"
S3 Template
Template
apiVersion: "flink.apache.org/v1beta1"
kind: "FlinkDeployment"
metadata:
name: "financial-job"
spec:
image: "cr.registry.res.cloud.wuxi-yqgcy.cn/mirror/financial-topic:1.5"
flinkVersion: "v1_17"
flinkConfiguration:
taskmanager.numberOfTaskSlots: "8"
s3a.endpoint: http://172.27.253.89:9000
s3a.access-key: minioadmin
s3a.secret-key: minioadmin
ingress:
template: "flink.k8s.io/{{namespace}}/{{name}}(/|$)(.*)"
className: "nginx"
annotations:
cert-manager.io/cluster-issuer: "self-signed-ca-issuer"
nginx.ingress.kubernetes.io/rewrite-target: "/$2"
serviceAccount: "flink"
podTemplate:
apiVersion: "v1"
kind: "Pod"
metadata:
name: "financial-job"
spec:
containers:
- name: "flink-main-container"
env:
- name: ENABLE_BUILT_IN_PLUGINS
value: flink-s3-fs-hadoop-1.17.2.jar
jobManager:
resource:
memory: "2048m"
cpu: 1
taskManager:
resource:
memory: "2048m"
cpu: 1
job:
jarURI: "local:///app/application.jar"
parallelism: 1
upgradeMode: "stateless"