We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent ef47f14 commit e026229Copy full SHA for e026229
controllers/flinkcluster_updater.go
@@ -404,7 +404,11 @@ func (updater *ClusterStatusUpdater) deriveClusterStatus(
404
switch recorded.State {
405
case "", v1beta1.ClusterStateCreating:
406
if runningComponents < totalComponents {
407
- status.State = v1beta1.ClusterStateCreating
+ if runningComponents == 0 {
408
+ status.State = v1beta1.ClusterStateStopped
409
+ } else {
410
+ status.State = v1beta1.ClusterStateCreating
411
+ }
412
} else {
413
status.State = v1beta1.ClusterStateRunning
414
}
0 commit comments