[flink-kubernetes-operator] branch main updated: [FLINK-28694] Set pipeline.name to resource name by default for application deployments

[gyfora]

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 0a1a68c9 [FLINK-28694] Set pipeline.name to resource name by default 
for application deployments
0a1a68c9 is described below

commit 0a1a68c9a88ad3055dcf6630e23ce89df7d23a97
Author: Nicholas Jiang <programg...@163.com>
AuthorDate: Wed Aug 10 08:27:27 2022 -0700

    [FLINK-28694] Set pipeline.name to resource name by default for application 
deployments
---
 .../apache/flink/kubernetes/operator/config/FlinkConfigBuilder.java    | 3 +++
 .../flink/kubernetes/operator/config/FlinkConfigBuilderTest.java       | 2 ++
 2 files changed, 5 insertions(+)

diff --git 
a/flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/config/FlinkConfigBuilder.java
 
b/flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/config/FlinkConfigBuilder.java
index 706d1108..fff4b71d 100644
--- 
a/flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/config/FlinkConfigBuilder.java
+++ 
b/flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/config/FlinkConfigBuilder.java
@@ -136,6 +136,9 @@ public class FlinkConfigBuilder {
         setDefaultConf(CANCEL_ENABLE, false);
 
         if (spec.getJob() != null) {
+            // Set 'pipeline.name' to resource name by default for application 
deployments.
+            setDefaultConf(PipelineOptions.NAME, clusterId);
+
             // With last-state upgrade mode, set the default value of
             // 'execution.checkpointing.interval'
             // to 5 minutes when HA is enabled.
diff --git 
a/flink-kubernetes-operator/src/test/java/org/apache/flink/kubernetes/operator/config/FlinkConfigBuilderTest.java
 
b/flink-kubernetes-operator/src/test/java/org/apache/flink/kubernetes/operator/config/FlinkConfigBuilderTest.java
index 81423097..a29018e3 100644
--- 
a/flink-kubernetes-operator/src/test/java/org/apache/flink/kubernetes/operator/config/FlinkConfigBuilderTest.java
+++ 
b/flink-kubernetes-operator/src/test/java/org/apache/flink/kubernetes/operator/config/FlinkConfigBuilderTest.java
@@ -121,6 +121,8 @@ public class FlinkConfigBuilderTest {
                 KubernetesConfigOptions.ServiceExposedType.ClusterIP,
                 
configuration.get(KubernetesConfigOptions.REST_SERVICE_EXPOSED_TYPE));
         Assertions.assertEquals(false, 
configuration.get(WebOptions.CANCEL_ENABLE));
+        Assertions.assertEquals(
+                flinkDeployment.getMetadata().getName(), 
configuration.get(PipelineOptions.NAME));
 
         FlinkDeployment deployment = 
ReconciliationUtils.clone(flinkDeployment);
         deployment