You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by gy...@apache.org on 2022/02/23 06:16:13 UTC
[flink-kubernetes-operator] branch main updated: [FLINK-26216] Make 'replicas' work in JobManager Spec
This is an automated email from the ASF dual-hosted git repository.
gyfora pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/flink-kubernetes-operator.git
The following commit(s) were added to refs/heads/main by this push:
new 5bd3b34 [FLINK-26216] Make 'replicas' work in JobManager Spec
5bd3b34 is described below
commit 5bd3b346c378e1562ac9d0cb4725e1e0189265da
Author: bgeng777 <ge...@alibaba-inc.com>
AuthorDate: Wed Feb 23 10:28:16 2022 +0800
[FLINK-26216] Make 'replicas' work in JobManager Spec
Closes #15
---
.../apache/flink/kubernetes/operator/utils/FlinkConfigBuilder.java | 5 +++++
.../flink/kubernetes/operator/utils/FlinkConfigBuilderTest.java | 4 ++++
2 files changed, 9 insertions(+)
diff --git a/flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/utils/FlinkConfigBuilder.java b/flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/utils/FlinkConfigBuilder.java
index eb54998..89fe458 100644
--- a/flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/utils/FlinkConfigBuilder.java
+++ b/flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/utils/FlinkConfigBuilder.java
@@ -119,6 +119,11 @@ public class FlinkConfigBuilder {
spec.getJobManager().getPodTemplate(),
effectiveConfig,
true);
+ if (spec.getJobManager().getReplicas() > 0) {
+ effectiveConfig.set(
+ KubernetesConfigOptions.KUBERNETES_JOBMANAGER_REPLICAS,
+ spec.getJobManager().getReplicas());
+ }
}
}
return this;
diff --git a/flink-kubernetes-operator/src/test/java/org/apache/flink/kubernetes/operator/utils/FlinkConfigBuilderTest.java b/flink-kubernetes-operator/src/test/java/org/apache/flink/kubernetes/operator/utils/FlinkConfigBuilderTest.java
index eb43bfc..1e4caa2 100644
--- a/flink-kubernetes-operator/src/test/java/org/apache/flink/kubernetes/operator/utils/FlinkConfigBuilderTest.java
+++ b/flink-kubernetes-operator/src/test/java/org/apache/flink/kubernetes/operator/utils/FlinkConfigBuilderTest.java
@@ -67,6 +67,7 @@ public class FlinkConfigBuilderTest {
flinkDeployment.getSpec().setPodTemplate(pod0);
flinkDeployment.getSpec().setIngressDomain("test.com");
flinkDeployment.getSpec().getJobManager().setPodTemplate(pod1);
+ flinkDeployment.getSpec().getJobManager().setReplicas(2);
flinkDeployment.getSpec().getTaskManager().setPodTemplate(pod2);
flinkDeployment.getSpec().getJob().setParallelism(2);
}
@@ -148,6 +149,9 @@ public class FlinkConfigBuilderTest {
Assert.assertEquals(
Double.valueOf(1), configuration.get(KubernetesConfigOptions.JOB_MANAGER_CPU));
Assert.assertEquals("pod1 api version", jmPod.getApiVersion());
+ Assert.assertEquals(
+ Integer.valueOf(2),
+ configuration.get(KubernetesConfigOptions.KUBERNETES_JOBMANAGER_REPLICAS));
}
@Test