diff --git a/pkg/flink/resources.go b/pkg/flink/resources.go index 8e84e2e..2e8f64e 100644 --- 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)