D. Draco O'Brien
08/17/2024, 3:59 PMapiVersion: <http://flinkoperator.k8s.io/v1beta1|flinkoperator.k8s.io/v1beta1>
kind: FlinkDeployment
metadata:
name: job-1
spec:
image: flink:1.19.0-scala_2.12-java11
flinkVersion: v1_19
jobManager:
accessScope: cluster
ports:
rpc: 6123
blob: 6124
query: 6125
taskManager:
replicas: 2
job:
jarURI: "path/to/your/job-1.jar"
parallelism: 2
upgradeMode: stateless
stateBackend: filesystem
savepointTriggerNonce: ""
---
apiVersion: <http://flinkoperator.k8s.io/v1beta1|flinkoperator.k8s.io/v1beta1>
kind: FlinkDeployment
metadata:
name: job-2
spec:
# Similar spec as above, just change the details for job-2
image: flink:1.19.0-scala_2.12-java11
flinkVersion: v1_19
jobManager:
...
taskManager:
...
job:
jarURI: "path/to/your/job-2.jar"
parallelism: 2
upgradeMode: stateless
stateBackend: filesystem
savepointTriggerNonce: ""