[feat] support run_mode=debug for ddc fe and ms

Author: jinyang09

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 {

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