diff --git a/cluster/syncer/statefulset.go b/cluster/syncer/statefulset.go index 50d726607..544ca15e9 100644 --- a/cluster/syncer/statefulset.go +++ b/cluster/syncer/statefulset.go @@ -185,8 +185,7 @@ func (s *StatefulSetSyncer) updatePod(ctx context.Context) error { log.Info("statefulSet was changed, run update") if s.sfs.Status.ReadyReplicas < s.sfs.Status.Replicas { - log.Info("can't start/continue 'update': waiting for all replicas are ready") - return nil + return fmt.Errorf("can't start/continue 'update': waiting for all replicas are ready") } pods := corev1.PodList{}