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/27 07:20:38 UTC

[flink-kubernetes-operator] branch main updated: [hotfix] copy base config in config builder

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 e2ac688  [hotfix] copy base config in config builder
e2ac688 is described below

commit e2ac68894cebf203cd16d559319a37205546a4da
Author: Matyas Orhidi <ma...@apple.com>
AuthorDate: Fri Feb 25 15:21:17 2022 +0100

    [hotfix] copy base config in config builder
---
 .../org/apache/flink/kubernetes/operator/utils/FlinkConfigBuilder.java  | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

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 8f21342..07ff83a 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
@@ -53,7 +53,7 @@ public class FlinkConfigBuilder {
     public FlinkConfigBuilder(FlinkDeployment deploy, Configuration flinkConfig) {
         this.deploy = deploy;
         this.spec = this.deploy.getSpec();
-        this.effectiveConfig = flinkConfig;
+        this.effectiveConfig = new Configuration(flinkConfig);
     }
 
     public FlinkConfigBuilder applyImage() {