[FLINK-26216] Make 'replicas' work in JobManager Spec

• Type: Sub-task
• Status: Closed
• Priority: Minor
• Resolution: Fixed
• Fix Version/s: kubernetes-operator-0.1.0
• Component/s: Kubernetes Operator
• Labels: pull-request-available
• Assignee: Biao Geng
• Reporter: Biao Geng
• Created: 17/Feb/22 11:30
• Updated: 27/Mar/22 13:16
• Resolved: 23/Feb/22 06:17

Description

In our flink kubernetes operator's cr, we allow users to set the replica of JobManager.
But in our FlinkUtils#getEffectiveConfig method, we currently not set this value from the yaml file and as a result, the replicas will not work and the default value(i.e. 1) will be applied.
Though we believe one JM with KubernetesHaService should be enough for most HA cases, the replicas field of JM also makes sense since more than one JM can reduce down time and make recovery of JM failure faster.

Issue Links

• links to: GitHub Pull Request #15