Fix: check if StatefulSet is set as PVC owner ref (#206)

spotify · Jan 13, 2022 · fee6b50 · fee6b50
1 parent b71d0dc
commit fee6b50
Showing 1 changed file with 4 additions and 2 deletions.
diff --git a/controllers/flinkcluster_reconciler.go b/controllers/flinkcluster_reconciler.go
@@ -476,8 +476,10 @@ func (reconciler *ClusterReconciler) reconcilePersistentVolumeClaim(pvc *corev1.
 	ctx := reconciler.context
 	k8sClient := reconciler.k8sClient
 
-	if len(pvc.GetOwnerReferences()) != 0 {
-		return nil
+	for _, ownerRef := range pvc.GetOwnerReferences() {
+		if ownerRef.Kind == sset.Kind {
+			return nil
+		}
 	}
 
 	patch := fmt.Sprintf(