search

GoogleCloudPlatform / flink-on-k8s-operator

[DEPRECATED] Kubernetes operator for managing the lifecycle of Apache Flink and Beam applications.
Apache License 2.0
658 stars 266 forks source link

Does flink operator support flink1.12? #438

Open william-wang opened 3 years ago

william-wang commented 3 years ago

flink operator supports per-job mode and session mode deployment. It is found that the per-job mode is not supported in flink1.12 anymore. Does flink-operator still support job cluster flink1.12?

sv3ndk commented 3 years ago

Hi William, I'm currently experimenting with the flink-on-k8s-operator and Flink 1.12 and so far it works pretty well. I successfully deployed both to Minikube and to an EKS cluster, each time in per-job mode. The operator takes care for taking a savepoint before an upate and then restart from that savepoint. Since we're using a recent version of K8s, we had to patch the operator manually as described here (https://github.com/GoogleCloudPlatform/flink-on-k8s-operator/issues/266#issuecomment-659938138) in order to deploy it, although that's quickly done (just a line to edit). I've not experimented with session mode.