Fixed wrong uid field in listing pvcs (#589)

Author: powerfooI

internal/resource/observer/utils.go

@@ -141,7 +141,7 @@ func (m *OBServerManager) setRecoveryStatus() {
 
 func (m *OBServerManager) getPVCs() (*corev1.PersistentVolumeClaimList, error) {
 	pvcs := &corev1.PersistentVolumeClaimList{}
-	err := m.K8sResClient.List(m.Ctx, pvcs, client.InNamespace(m.OBServer.Namespace), client.MatchingLabels{oceanbaseconst.LabelRefUID: m.OBServer.Labels[oceanbaseconst.LabelRefUID]})
+	err := m.K8sResClient.List(m.Ctx, pvcs, client.InNamespace(m.OBServer.Namespace), client.MatchingLabels{oceanbaseconst.LabelRefUID: string(m.OBServer.UID)})
 	if err != nil {
 		return nil, errors.Wrap(err, "list pvc")
 	}
@@ -667,7 +667,7 @@ func (m *OBServerManager) cleanWorkerK8sResource() error {
 	pvc := &corev1.PersistentVolumeClaim{}
 	if err := m.K8sResClient.DeleteAllOf(m.Ctx, pvc,
 		client.InNamespace(m.OBServer.Namespace),
-		client.MatchingLabels{oceanbaseconst.LabelRefUID: m.OBServer.Labels[oceanbaseconst.LabelRefUID]},
+		client.MatchingLabels{oceanbaseconst.LabelRefUID: string(m.OBServer.UID)},
 	); err != nil {
 		errs = stderrs.Join(errs, errors.Wrap(err, "Failed to delete pvc"))
 	}