Replies: 1 comment
-
Get following error if I try to change flink version. |
Beta Was this translation helpful? Give feedback.
0 replies
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment
-
I was able to successfully update deployement beam-job-server with image apache/beam_flink1.15_job_server:2.43.0.
I am looking to update flink version as well as SDK as well. Getting error if I apply following cluster yaml.
apiVersion: flinkoperator.k8s.io/v1beta1
kind: FlinkCluster
metadata:
name: beam-flink-cluster
spec:
flinkVersion: 1.15
image:
name: flink:1.15
taskManager:
replicas: 2
sidecars:
- name: beam-worker-pool
image: apache/beam_python3.7_sdk:2.43.0
args: ["--worker_pool"]
flinkProperties:
taskmanager.numberOfTaskSlots: "1"
Beta Was this translation helpful? Give feedback.
All reactions