Fix: update cluster on scale up (#871)

regadas · web-flow · commit a5010e7a0fd9 · 2025-02-13T08:31:52.000-05:00
diff --git a/controllers/flinkcluster/flinkcluster_util.go b/controllers/flinkcluster/flinkcluster_util.go
@@ -525,6 +525,10 @@ func shouldUpdateJob(observed *ObservedClusterState) bool {
 }
 
 func shouldUpdateCluster(observed *ObservedClusterState) bool {
+	if isScaleUpdate(observed.revisions, observed.cluster) {
+		return observed.updateState == UpdateStateInProgress
+	}
+
 	var job = observed.cluster.Status.Components.Job
 	return !job.IsActive() && observed.updateState == UpdateStateInProgress
 }

Original file line number	Diff line number	Diff line change
`@@ -525,6 +525,10 @@ func shouldUpdateJob(observed *ObservedClusterState) bool {`
`525`	`525`	`}`
`526`	`526`
`527`	`527`	`func shouldUpdateCluster(observed *ObservedClusterState) bool {`
	`528`	`+ if isScaleUpdate(observed.revisions, observed.cluster) {`
	`529`	`+ return observed.updateState == UpdateStateInProgress`
	`530`	`+ }`
	`531`	`+`
`528`	`532`	`var job = observed.cluster.Status.Components.Job`
`529`	`533`	`return !job.IsActive() && observed.updateState == UpdateStateInProgress`
`530`	`534`	`}`