Skip to content

Commit 38dbb32

Browse files
committed
operator v1: try to avoid problems where status is internally overridden
1 parent 390e4b6 commit 38dbb32

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

operator/pkg/resources/statefulset_scale.go

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -291,12 +291,12 @@ func (r *StatefulSetResource) handleDecommission(ctx context.Context, l logr.Log
291291
if err != nil {
292292
return err
293293
}
294-
cluster.Status.DecommissioningNode = nil
294+
cluster.SetDecommissionBrokerID(nil)
295295
err = r.Status().Update(ctx, cluster)
296296
if err == nil {
297297
log.Info("Cleared decomm broker ID from status")
298298
// sync original cluster variable to avoid conflicts on subsequent operations
299-
r.pandaCluster.Status = cluster.Status
299+
r.pandaCluster.SetDecommissionBrokerID(nil)
300300
}
301301
return err
302302
})

0 commit comments

Comments
 (0)