Default deploymentType should be StatefulSet (#413)

spotify · Jun 3, 2022 · 9f50d91 · 9f50d91
1 parent dfad3ef
commit 9f50d91
Showing 1 changed file with 2 additions and 1 deletion.
diff --git 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)
 		}