Unsubscribe

Unsubscribe Regards, Amit Bhatia

Getting Errors in Standby Jobmanager pod during installation & after restart on k8s

Hi, We have deployed two jobmanagers in HA mode on kubernetes using k8s configmap solution with deployment controller. During Installation and after restart we are getting below errors in standby jobmanager. 2021-10-25 11:17:46,397 ERROR io.fabric8.kubernetes.client.extended.leaderelection.Leader

Re: Queries regarding Flink upgrade strategies

e same Flink cluster > is not supported. > > @Yang Wang Do you have any recommendations you > could share in this regard? > > Best, > Matthias > > On Fri, Aug 27, 2021 at 2:44 PM Amit Bhatia > wrote: > >> Hi Matthias, >> >> What you mention is a li

Re: Queries regarding Flink upgrade strategies

? > > Best, > Matthias > > On Fri, Aug 27, 2021 at 11:05 AM Amit Bhatia > wrote: > >> Hi Matthias, >> >> Thanks for the information but this upgrade is looking like on native >> (physical/virtual) deployment. >> I want to understand the upgrade strat

Re: Queries regarding Flink upgrade strategies

Hi Matthias, Thanks for the information but this upgrade is looking like on native (physical/virtual) deployment. I want to understand the upgrade strategies on kubernetes deployments where Flink is running in pods. If you could help in that area it would be great. Regards, Amit Bhatia On Thu

Queries regarding Flink upgrade strategies

rent versions then will this cause any corruption/failure for running Jobs? Regards, Amit Bhatia

Metric counter gets reset when leader jobmanager changes in Flink native K8s HA solution

Hi, We have configured jobmanager HA with flink 1.12.1 on the k8s environment. We have implemented a HA solution using Native K8s HA solution ( https://cwiki.apache.org/confluence/display/FLINK/FLIP-144%3A+Native+Kubernetes+HA+for+Flink). We have used deployment controller for both jobmanager & ta

Flink minimum resource recommendation on k8s cluster

Hi, Is there any minimum resource ( CPU & Memory) recommendation to start flink jobmanager and taskmanager pods on k8s cluster. Regards, Amit Bhatia

Re: Flink Jobmanager HA deployment on k8s

So i have below queries on this: 1) what is the correct way to start three jobmanager replicas with zk ? Is there any link which explains this deployment scenario and configuration ? 2) How we'll identify that out of three replicas, which Job Manager replica is the leader ? Regards, Amit Bha

Flink Jobmanager HA deployment on k8s

Hi, I am deploying Flink 1.12 on K8s. Can anyone confirm if we can deploy multiple job manager pods in K8s for HA or it should always be only a single job manager pod ? Regards, Amit Bhatia