From a08f3f435fc78c2a4db59a919c93efff676173fd Mon Sep 17 00:00:00 2001
From: Filipe Regadas <filiperegadas@gmail.com>
Date: Wed, 28 Apr 2021 15:24:52 +0100
Subject: [PATCH] Fix cluster state stuck on creating

---
 controllers/flinkcluster_updater.go | 6 +++++-
 1 file changed, 5 insertions(+), 1 deletion(-)

diff --git a/controllers/flinkcluster_updater.go b/controllers/flinkcluster_updater.go
index 247267c6..34a9e32d 100644
--- a/controllers/flinkcluster_updater.go
+++ b/controllers/flinkcluster_updater.go
@@ -404,7 +404,11 @@ func (updater *ClusterStatusUpdater) deriveClusterStatus(
 	switch recorded.State {
 	case "", v1beta1.ClusterStateCreating:
 		if runningComponents < totalComponents {
-			status.State = v1beta1.ClusterStateCreating
+			if runningComponents == 0 {
+				status.State = v1beta1.ClusterStateStopped
+			} else {
+				status.State = v1beta1.ClusterStateCreating
+			}
 		} else {
 			status.State = v1beta1.ClusterStateRunning
 		}