that statement is more from within a single job. Y...
# random
d
that statement is more from within a single job. You need multiple jobs/jars is best. Something like
Copy code
apiVersion: <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: ""