Fix failing test

spotify · Jun 1, 2022 · d54f057 · d54f057
1 parent aad80e7
commit d54f057
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/controllers/flinkcluster/flinkcluster_updater_test.go b/controllers/flinkcluster/flinkcluster_updater_test.go
@@ -209,7 +209,7 @@ func TestClusterStatus(t *testing.T) {
 		}
 
 		var updater = &ClusterStatusUpdater{log: log.Log, observed: observed}
-		cluster := v1beta1.FlinkCluster{Status: oldStatus}
+		cluster := v1beta1.FlinkCluster{Status: oldStatus, Spec: v1beta1.FlinkClusterSpec{TaskManager: &v1beta1.TaskManagerSpec{DeploymentType: v1beta1.DeploymentTypeStatefulset}}}
 		newStatus := updater.deriveClusterStatus(&cluster, &observed)
 		assert.Assert(t, updater.isStatusChanged(oldStatus, newStatus))
 		assert.Equal(t, newStatus.State, v1beta1.ClusterStateRunning)