fix: redis cluster creates failed and always is deleting (#9422)

Author: wangyelei

controllers/apps/transformer_component_account.go

@@ -77,7 +77,7 @@ func (t *componentAccountTransformer) Transform(ctx graph.TransformContext, dag
 		existSecretCopy := existSecret.DeepCopy()
 		ctrlutil.MergeMetadataMapInplace(secret.Labels, &existSecretCopy.Labels)
 		ctrlutil.MergeMetadataMapInplace(secret.Annotations, &existSecretCopy.Annotations)
-		if !reflect.DeepEqual(existSecret, existSecretCopy) {
+		if !reflect.DeepEqual(existSecret, existSecretCopy) || !model.IsOwnerOf(transCtx.ComponentOrig, existSecret) {
 			graphCli.Update(dag, existSecret, existSecretCopy, inUniversalContext4G())
 		}
 	}

controllers/apps/transformer_component_vars.go

@@ -182,7 +182,7 @@ func createOrUpdateEnvConfigMap(ctx graph.TransformContext, dag *graph.DAG, data
 			SetData(data).
 			GetObject()
 		graphCli.Create(dag, obj, inDataContext4G())
-	} else if !reflect.DeepEqual(envObj.Data, data) {
+	} else if !reflect.DeepEqual(envObj.Data, data) || !model.IsOwnerOf(transCtx.ComponentOrig, envObj) {
 		envObjCopy := envObj.DeepCopy()
 		envObjCopy.Data = data
 		graphCli.Update(dag, envObj, envObjCopy, inDataContext4G())

pkg/controller/component/component_lifecycle_action_utils.go

@@ -231,7 +231,7 @@ func renderActionCmdJob(ctx context.Context, cli client.Reader, actionCtx *Actio
 				},
 			},
 		}
-		if err := BuildJobSchdulingPolicy(jobObj, actionCtx.component, actionCtx.cluster); err != nil {
+		if err := BuildJobSchdulingPolicy(jobObj, actionCtx.component.DeepCopy(), actionCtx.cluster); err != nil {
 			return nil, err
 		}
 		for i := range jobObj.Spec.Template.Spec.Containers {

pkg/controller/component/component_lifecycle_action_utils_test.go

@@ -157,12 +157,30 @@ var _ = Describe("Component LifeCycle Action Utils Test", func() {
 				}}
 				Expect(k8sClient.Status().Update(ctx, &pod)).Should(Succeed())
 			}
+			comp.Spec.SchedulingPolicy = &appsv1alpha1.SchedulingPolicy{
+				Affinity: &corev1.Affinity{
+					PodAntiAffinity: &corev1.PodAntiAffinity{
+						PreferredDuringSchedulingIgnoredDuringExecution: []corev1.WeightedPodAffinityTerm{{
+							Weight: 1,
+							PodAffinityTerm: corev1.PodAffinityTerm{
+								LabelSelector: &metav1.LabelSelector{
+									MatchLabels: map[string]string{
+										constant.AppInstanceLabelKey: clusterName,
+									},
+								},
+							},
+						}},
+					},
+				},
+			}
 			actionCtx, err = NewActionContext(cluster, comp, nil, synthesizeComp.LifecycleActions, synthesizeComp.ScriptTemplates, PreTerminateAction)
 			Expect(err).Should(Succeed())
 			renderJob, err := renderActionCmdJob(testCtx.Ctx, testCtx.Cli, actionCtx)
 			Expect(err).Should(Succeed())
 			Expect(renderJob).ShouldNot(BeNil())
-			Expect(len(renderJob.Spec.Template.Spec.Containers[0].Env) == 11).Should(BeTrue())
+			Expect(renderJob.Spec.Template.Spec.Containers[0].Env).ShouldNot(BeNil())
+			Expect(renderJob.Spec.Template.Spec.Affinity.PodAntiAffinity).Should(BeNil())
+			Expect(actionCtx.component.Spec.SchedulingPolicy.Affinity.PodAntiAffinity).ShouldNot(BeNil())
 			compListExist := false
 			deletingCompListExist := false
 			undeletedCompListExist := false

pkg/controller/component/vars.go

@@ -713,7 +713,7 @@ func resolveServiceLoadBalancerRef(ctx context.Context, cli client.Reader, synth
 		}
 		return &corev1.EnvVar{Name: defineKey, Value: *points}, nil, nil
 	}
-	return resolveServiceVarRefLow(ctx, cli, synthesizedComp, selector, selector.Host, resolveLoadBalancer)
+	return resolveServiceVarRefLow(ctx, cli, synthesizedComp, selector, selector.LoadBalancer, resolveLoadBalancer)
 }
 
 func composeLoadBalancerValueFromServices(obj any) *string {