diff --git a/pkg/controller/sub_controller/disaggregated_cluster/disaggregated_fe/controller.go b/pkg/controller/sub_controller/disaggregated_cluster/disaggregated_fe/controller.go index cef6e4c1..a4dfb322 100644 --- a/pkg/controller/sub_controller/disaggregated_cluster/disaggregated_fe/controller.go +++ b/pkg/controller/sub_controller/disaggregated_cluster/disaggregated_fe/controller.go @@ -270,6 +270,9 @@ func (dfc *DisaggregatedFEController) initialFEStatus(ddc *v1.DorisDisaggregated func (dfc *DisaggregatedFEController) reconcileStatefulset(ctx context.Context, st *appv1.StatefulSet, cluster *v1.DorisDisaggregatedCluster) (*sc.Event, error) { var est appv1.StatefulSet if err := dfc.K8sclient.Get(ctx, types.NamespacedName{Namespace: st.Namespace, Name: st.Name}, &est); apierrors.IsNotFound(err) { + // add downlaodAPI volume Mounts + dfc.DisaggregatedSubDefaultController.AddDownwardAPI(st) + if err = k8s.CreateClientObject(ctx, dfc.K8sclient, st); err != nil { klog.Errorf("disaggregatedFEController reconcileStatefulset create statefulset namespace=%s name=%s failed, err=%s", st.Namespace, st.Name, err.Error()) return &sc.Event{Type: sc.EventWarning, Reason: sc.FECreateResourceFailed, Message: err.Error()}, err @@ -324,6 +327,7 @@ func (dfc *DisaggregatedFEController) reconcileStatefulset(ctx context.Context, ddc_annos := (resource.Annotations)(cluster.Annotations) msUniqueIdKey := strings.ToLower(fmt.Sprintf(v1.UpdateStatefulsetName, cluster.GetFEStatefulsetName())) ddc_annos.Add(msUniqueIdKey, "true") + dfc.DisaggregatedSubDefaultController.AddDownwardAPI(st) } return equal }); err != nil { diff --git a/pkg/controller/sub_controller/disaggregated_cluster/metaservice/controller.go b/pkg/controller/sub_controller/disaggregated_cluster/metaservice/controller.go index 0ac5166f..3fb9d7bc 100644 --- a/pkg/controller/sub_controller/disaggregated_cluster/metaservice/controller.go +++ b/pkg/controller/sub_controller/disaggregated_cluster/metaservice/controller.go @@ -190,6 +190,9 @@ func (dms *DisaggregatedMSController) Sync(ctx context.Context, obj client.Objec func (dms *DisaggregatedMSController) reconcileStatefulset(ctx context.Context, st *appv1.StatefulSet, ddc *v1.DorisDisaggregatedCluster) (*sc.Event, error) { var est appv1.StatefulSet if err := dms.K8sclient.Get(ctx, types.NamespacedName{Namespace: st.Namespace, Name: st.Name}, &est); apierrors.IsNotFound(err) { + // add downlaodAPI volume Mounts + dms.DisaggregatedSubDefaultController.AddDownwardAPI(st) + if err = k8s.CreateClientObject(ctx, dms.K8sclient, st); err != nil { klog.Errorf("dms controller reconcileStatefulset create statefulset namespace=%s name=%s failed, err=%s", st.Namespace, st.Name, err.Error()) return &sc.Event{Type: sc.EventWarning, Reason: sc.CGCreateResourceFailed, Message: err.Error()}, err @@ -217,6 +220,7 @@ func (dms *DisaggregatedMSController) reconcileStatefulset(ctx context.Context, ddc_annos := (resource.Annotations)(ddc.Annotations) msUniqueIdKey := strings.ToLower(fmt.Sprintf(v1.UpdateStatefulsetName, ddc.GetMSStatefulsetName())) ddc_annos.Add(msUniqueIdKey, "true") + dms.DisaggregatedSubDefaultController.AddDownwardAPI(st) } return equal