Fix: don't override env vars set in config (#120)

spotify · Mar 21, 2022 · 6dc2198 · 6dc2198
1 parent 09e2d7e
commit 6dc2198
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/pkg/flink/resources.go b/pkg/flink/resources.go
@@ -300,10 +300,10 @@ func NewFlinkCluster(config *Config, taskCtx FlinkTaskContext) (*flinkOp.FlinkCl
 		Kind:       KindFlinkCluster,
 		APIVersion: flinkOp.GroupVersion.String(),
 	}
-	cluster.Spec.EnvVars = []corev1.EnvVar{{
+	cluster.Spec.EnvVars = append(cluster.Spec.EnvVars, corev1.EnvVar{
 		Name:  stagedJarsEnvVarName,
 		Value: strings.Join(taskCtx.Job.JarFiles, " "),
-	}}
+	})
 
 	cluster.updateFlinkProperties(config, taskCtx)