Hi guys, I have been trying to submit a sample Pcollection job to a running FlinkDeployment job manager but it keeps failing. I shared this issue yesterday but I guess it wasn’t well understood. On figuring out further I found out that it requires a beam worker pool side cart to run the application without with it fails. The basic FlinkDeployment session cluster yaml format provided in the official documentation is as below.

apiVersion: <http://flink.apache.org/v1beta1|flink.apache.org/v1beta1>
kind: FlinkDeployment
metadata:
  namespace: default
  name: basic-example
spec:
  image: flink:1.15
  flinkVersion: v1_15
  flinkConfiguration:
    taskmanager.numberOfTaskSlots: "2"
  serviceAccount: flink
  jobManager:
    resource:
      memory: "2048m"
      cpu: 1
  taskManager:
    resource:
      memory: "2048m"
      cpu: 1

How do I add the beam worker pool in this yaml file, or how should I create it? Would greatly appreciate your support!