Re: Kubernetes HA Services - artifact for KubernetesHaServicesFactory

2021-01-22 Thread Ashish Nigam
e ConfigMap. Please note > the default service > account has enough permission. > > Of course, you could also set the config option > "kubernetes.service-account" to another service account > with enough permission. > > Best, > Yang > > Ashish Nigam 于20

Re: Kubernetes HA Services - artifact for KubernetesHaServicesFactory

2021-01-21 Thread Ashish Nigam
HA related codes have been > refactored from release 1.12. > Even though you copy the flink-kubernetes_2.12-1.12.1.jar to > /opt/flink/lib and make the KubernetesHaServicesFactory class > could be resolved. It will encounter other issues after then. > > Could you please try with th

Re: Kubernetes HA Services - artifact for KubernetesHaServicesFactory

2021-01-20 Thread Ashish Nigam
ternative is you could set the environment to enable the plugin[1]. > > [1]. > https://hub.docker.com/r/apache/flink/tags?page=1&ordering=last_updated&name=1.12.1 > [2]. > https://ci.apache.org/projects/flink/flink-docs-master/deployment/resource-providers/standalone/docker.ht

Re: Flink Jobmanager HA deployment on k8s

2021-01-19 Thread Ashish Nigam
Yang, For Application clusters, does it make sense to deploy JobManager as "Deployment" rather than as a "Job", as suggested in docs? I am asking this because I am thinking of deploying a job manager in HA mode even for application clusters. Thanks Ashish On Tue, Jan 19, 2021 at 6:16 AM Yang Wan

Kubernetes HA Services - artifact for KubernetesHaServicesFactory

2021-01-18 Thread Ashish Nigam
Hi, I am not able to identify maven artifact that will have implementation for this class org.apache.flink.kubernetes.highavailability.KubernetesHaServicesFactory I am using info in this link to test out HA implementation https://ci.apache.org/projects/flink/flink-docs-release-1.12/deployment/ha