Fix FlinkProperties template (#67)

spotify · Jul 1, 2021 · e20e0d7 · e20e0d7
1 parent e22a75f
commit e20e0d7
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/pkg/flink/resources.go b/pkg/flink/resources.go
@@ -255,7 +255,7 @@ func (fc *FlinkCluster) updateFlinkProperties(config *Config, taskCtx FlinkTaskC
 
 	result := make(map[string]string)
 	for k, v := range props {
-		tmpl, err := containerTmpl.Parse(v)
+		tmpl, err := flinkPropertiesTmpl.Parse(v)
 		if err != nil {
 			return err
 		}