Add flinkPropertiesSecret for supporting secret properties

api/v1beta1/flinkcluster_default_test.go

@@ -110,7 +110,8 @@ func TestSetDefault(t *testing.T) {
 				},
 				SecurityContext: nil,
 			},
-			FlinkProperties: nil,
+			FlinkProperties:       nil,
+			FlinkPropertiesSecret: nil,
 			HadoopConfig: &HadoopConfig{
 				MountPath: "/etc/hadoop/conf",
 			},
@@ -204,7 +205,8 @@ func TestSetNonDefault(t *testing.T) {
 					AfterJobCancelled: "KeepCluster",
 				},
 			},
-			FlinkProperties: nil,
+			FlinkProperties:       nil,
+			FlinkPropertiesSecret: nil,
 			HadoopConfig: &HadoopConfig{
 				MountPath: "/opt/flink/hadoop/conf",
 			},
@@ -268,7 +270,8 @@ func TestSetNonDefault(t *testing.T) {
 					AfterJobCancelled: "KeepCluster",
 				},
 			},
-			FlinkProperties: nil,
+			FlinkProperties:       nil,
+			FlinkPropertiesSecret: nil,
 			HadoopConfig: &HadoopConfig{
 				MountPath: "/opt/flink/hadoop/conf",
 			},

api/v1beta1/flinkcluster_types.go

@@ -447,9 +447,12 @@ type FlinkClusterSpec struct {
 	// TaskManager and job containers.
 	EnvFrom []corev1.EnvFromSource `json:"envFrom,omitempty"`
 
-	// Flink properties which are appened to flink-conf.yaml.
+	// Flink properties which are appended to flink-conf.yaml.
 	FlinkProperties map[string]string `json:"flinkProperties,omitempty"`
 
+	// Secret source of Flink properties which will be appended to flink-conf.yaml.
+	FlinkPropertiesSecret *corev1.SecretEnvSource `json:"flinkPropertiesSecret,omitempty"`
+
 	// Config for Hadoop.
 	HadoopConfig *HadoopConfig `json:"hadoopConfig,omitempty"`