diff --git a/pkg/cluster/pod.go b/pkg/cluster/pod.go
index 432597f7f..ea3e02dcd 100644
--- a/pkg/cluster/pod.go
+++ b/pkg/cluster/pod.go
@@ -203,6 +203,15 @@ func (c *Cluster) MigrateMasterPod(podName spec.NamespacedName) error {
 		c.logger.Warningf("pod %q is not a master", podName)
 		return nil
 	}
+	// we must have a statefulset in the cluster for the migration to work
+	if c.Statefulset == nil {
+		sset, err := c.KubeClient.StatefulSets(c.Namespace).Get(c.statefulSetName(), metav1.GetOptions{})
+		if err != nil {
+			return fmt.Errorf("could not retrieve cluster statefulset: %v", err)
+		}
+		c.Statefulset = sset
+	}
+	// We may not have a cached statefulset if the initial cluster sync has aborted, revert to the spec in that case.
 	if *c.Statefulset.Spec.Replicas == 1 {
 		c.logger.Warningf("single master pod for cluster %q, migration will cause longer downtime of the master instance", c.clusterName())
 	} else {
diff --git a/pkg/cluster/volumes.go b/pkg/cluster/volumes.go
index 42b5858fc..6f539f4ee 100644
--- a/pkg/cluster/volumes.go
+++ b/pkg/cluster/volumes.go
@@ -103,10 +103,10 @@ func (c *Cluster) resizeVolumes(newVolume spec.Volume, resizers []volumes.Volume
 
 	for _, pv := range pvs {
 		volumeSize := quantityToGigabyte(pv.Spec.Capacity[v1.ResourceStorage])
-		if volumeSize > newSize {
-			return fmt.Errorf("cannot shrink persistent volume")
-		}
-		if volumeSize == newSize {
+		if volumeSize >= newSize {
+			if volumeSize > newSize {
+				c.logger.Warningf("cannot shrink persistent volume")
+			}
 			continue
 		}
 		for _, resizer := range resizers {