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() {