From 9f50d911fda21db4c495dbce754640628cbfef75 Mon Sep 17 00:00:00 2001 From: Dhruv Batheja Date: Fri, 3 Jun 2022 08:15:29 +0200 Subject: [PATCH] Default deploymentType should be StatefulSet (#413) --- controllers/flinkcluster/flinkcluster_converter.go | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/controllers/flinkcluster/flinkcluster_converter.go b/controllers/flinkcluster/flinkcluster_converter.go index e23f3047..5f374349 100644 --- a/controllers/flinkcluster/flinkcluster_converter.go +++ b/controllers/flinkcluster/flinkcluster_converter.go @@ -98,7 +98,8 @@ func getDesiredClusterState(observed *ObservedClusterState) *model.DesiredCluste state.JmStatefulSet = newJobManagerStatefulSet(cluster) } - if cluster.Spec.TaskManager.DeploymentType == v1beta1.DeploymentTypeStatefulSet { + deploymentType := cluster.Spec.TaskManager.DeploymentType + if deploymentType == v1beta1.DeploymentTypeStatefulSet || deploymentType == "" { if !shouldCleanup(cluster, "TaskManagerStatefulSet") { state.TmStatefulSet = newTaskManagerStatefulSet(cluster) }