diff --git a/pkg/controller/sub_controller/disaggregated_cluster/metaservice/statefulset.go b/pkg/controller/sub_controller/disaggregated_cluster/metaservice/statefulset.go index e688daf2..3cddea23 100644 --- a/pkg/controller/sub_controller/disaggregated_cluster/metaservice/statefulset.go +++ b/pkg/controller/sub_controller/disaggregated_cluster/metaservice/statefulset.go @@ -73,6 +73,9 @@ func (dms *DisaggregatedMSController) newStatefulset(ddc *v1.DorisDisaggregatedC } replicas := metadata.GetInt32Pointer(v1.DefaultMetaserviceNumber) + if msSpec.Replicas != nil { + replicas = msSpec.Replicas + } func() { st.Spec.Replicas = replicas