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
Uh oh!
There was an error while loading. Please reload this page.
-
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