| 1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859 |
- apiVersion: apps/v1
- kind: Deployment
- metadata:
- name: flink-taskmanager
- spec:
- replicas: 2
- selector:
- matchLabels:
- app: flink
- component: taskmanager
- template:
- metadata:
- labels:
- app: flink
- component: taskmanager
- spec:
- containers:
- - name: taskmanager
- image: arm64v8/flink:1.14.6-scala_2.12
- # image: apache/flink:1.10.3
- # image: apache/flink:1.12.0-scala_2.11
- args: ["taskmanager"]
- ports:
- - containerPort: 6122
- name: rpc
- - containerPort: 6125
- name: query-state
- livenessProbe:
- tcpSocket:
- port: 6122
- initialDelaySeconds: 30
- periodSeconds: 60
- volumeMounts:
- - name: flink-config-volume
- mountPath: /opt/flink/conf/
- securityContext:
- runAsUser: 9999 # refers to user _flink_ from official flink image, change if necessary
- # - name: beam-worker-pool
- # #image: apache/beam_python3.7_sdk
- # image: arm64v8/flink:1.14.6-scala_2.12
- # args: ["--worker_pool"]
- # ports:
- # - containerPort: 50000
- # name: pool
- # livenessProbe:
- # tcpSocket:
- # port: 50000
- # initialDelaySeconds: 30
- # periodSeconds: 60
- volumes:
- - name: flink-config-volume
- configMap:
- name: flink-config
- items:
- - key: flink-conf.yaml
- path: flink-conf.yaml
- - key: log4j-console.properties
- path: log4j-console.properties
|
