Skip to content

Commit 9f404f3

Browse files
authored
Merge pull request apache#449 from ztonny/master
[Bug] fix issue apache#448
2 parents a8ad8e1 + 094081c commit 9f404f3

File tree

1 file changed

+4
-11
lines changed
  • pkg/controller/sub_controller/disaggregated_cluster/disaggregated_fe

1 file changed

+4
-11
lines changed

pkg/controller/sub_controller/disaggregated_cluster/disaggregated_fe/statefulset.go

Lines changed: 4 additions & 11 deletions
Original file line numberDiff line numberDiff line change
@@ -19,13 +19,14 @@ package disaggregated_fe
1919

2020
import (
2121
"fmt"
22-
"github.com/apache/doris-operator/api/disaggregated/v1"
22+
"strconv"
23+
24+
v1 "github.com/apache/doris-operator/api/disaggregated/v1"
2325
"github.com/apache/doris-operator/pkg/common/utils/resource"
2426
sub "github.com/apache/doris-operator/pkg/controller/sub_controller"
2527
appv1 "k8s.io/api/apps/v1"
2628
corev1 "k8s.io/api/core/v1"
2729
metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
28-
"strconv"
2930
)
3031

3132
const (
@@ -38,7 +39,6 @@ const (
3839
//DefaultStorageSize int64 = 107374182400
3940
basic_auth_path = "/etc/basic_auth"
4041
auth_volume_name = "basic-auth"
41-
4242
)
4343

4444
func (dfc *DisaggregatedFEController) newFEPodsSelector(ddcName string) map[string]string {
@@ -61,7 +61,7 @@ func (dfc *DisaggregatedFEController) NewStatefulset(ddc *v1.DorisDisaggregatedC
6161
_, _, vcts := dfc.BuildVolumesVolumeMountsAndPVCs(confMap, v1.DisaggregatedFE, &spec.CommonSpec)
6262
pts := dfc.NewPodTemplateSpec(ddc, confMap)
6363
//add last supplementary spec. if add new config in ddc spec and the config need add in pod, use the follow function to add.
64-
dfc.DisaggregatedSubDefaultController.AddClusterSpecForPodTemplate(v1.DisaggregatedFE,confMap, &ddc.Spec, &pts)
64+
dfc.DisaggregatedSubDefaultController.AddClusterSpecForPodTemplate(v1.DisaggregatedFE, confMap, &ddc.Spec, &pts)
6565
st := dfc.NewDefaultStatefulset(ddc)
6666
//metadata
6767
func() {
@@ -134,13 +134,6 @@ func (dfc *DisaggregatedFEController) NewFEContainer(ddc *v1.DorisDisaggregatedC
134134
c.Env = append(c.Env, resource.GetPodDefaultEnv()...)
135135
c.Env = append(c.Env, dfc.newSpecificEnvs(ddc)...)
136136

137-
if ddc.Spec.FeSpec.ElectionNumber != nil {
138-
c.Env = append(c.Env, corev1.EnvVar{
139-
Name: resource.ENV_FE_ELECT_NUMBER,
140-
Value: strconv.FormatInt(int64(*ddc.Spec.FeSpec.ElectionNumber), 10),
141-
})
142-
}
143-
144137
resource.BuildDisaggregatedProbe(&c, &ddc.Spec.FeSpec.CommonSpec, v1.DisaggregatedFE)
145138
_, vms, _ := dfc.BuildVolumesVolumeMountsAndPVCs(cvs, v1.DisaggregatedFE, &ddc.Spec.FeSpec.CommonSpec)
146139
_, cmvms := dfc.BuildDefaultConfigMapVolumesVolumeMounts(ddc.Spec.FeSpec.ConfigMaps)

0 commit comments

Comments
 (0)