Merge pull request #291 from catpineapple/fix-service-access-in-different-ns

[fix](ddc)fix fe service access in diff namespace

Author: smiletan

api/disaggregated/v1/unique_id.go

@@ -68,6 +68,10 @@ func (ddc *DorisDisaggregatedCluster) GetFEServiceName() string {
 	return ddc.Name + "-" + "fe"
 }
 
+func (ddc *DorisDisaggregatedCluster) GetFEVIPAddresss() string {
+	return ddc.GetFEServiceName() + "." + ddc.Namespace
+}
+
 func (ddc *DorisDisaggregatedCluster) GetFEInternalServiceName() string {
 	return ddc.Name + "-" + "fe-internal"
 }

pkg/controller/sub_controller/disaggregated_cluster/computegroups/controller.go

@@ -496,9 +496,8 @@ func (dcgs *DisaggregatedComputeGroupsController) scaledOutBENodesBySQL(
 	adminUserName, password := resource.GetDorisLoginInformation(secret)
 
 	// get host and port
-	serviceName := cluster.GetFEServiceName()
 	// When the operator and dcr are deployed in different namespace, it will be inaccessible, so need to add the dcr svc namespace
-	host := serviceName + "." + cluster.Namespace
+	host := cluster.GetFEVIPAddresss()
 	confMap := dcgs.GetConfigValuesFromConfigMaps(cluster.Namespace, resource.FE_RESOLVEKEY, cluster.Spec.FeSpec.ConfigMaps)
 	queryPort := resource.GetPort(confMap, resource.QUERY_PORT)
 

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

@@ -319,7 +319,7 @@ func (dcgs *DisaggregatedComputeGroupsController) newSpecificEnvs(ddc *dv1.Doris
 	fqp := resource.GetPort(confMap, resource.QUERY_PORT)
 	fqpStr := strconv.FormatInt(int64(fqp), 10)
 	//use fe service name as access address.
-	feAddr := ddc.GetFEServiceName()
+	feAddr := ddc.GetFEVIPAddresss()
 	cgEnvs = append(cgEnvs,
 		corev1.EnvVar{Name: resource.STATEFULSET_NAME, Value: stsName},
 		corev1.EnvVar{Name: resource.COMPUTE_GROUP_NAME, Value: ddc.GetCGName(cg)},

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

@@ -308,9 +308,8 @@ func (dfc *DisaggregatedFEController) dropFEBySQLClient(ctx context.Context, k8s
 	adminUserName, password := resource.GetDorisLoginInformation(secret)
 
 	// get host and port
-	serviceName := cluster.GetFEServiceName()
 	// When the operator and dcr are deployed in different namespace, it will be inaccessible, so need to add the dcr svc namespace
-	host := serviceName + "." + cluster.Namespace
+	host := cluster.GetFEVIPAddresss()
 	confMap := dfc.GetConfigValuesFromConfigMaps(cluster.Namespace, resource.FE_RESOLVEKEY, cluster.Spec.FeSpec.ConfigMaps)
 	queryPort := resource.GetPort(confMap, resource.QUERY_PORT)
 

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

@@ -297,7 +297,7 @@ func (dfc *DisaggregatedFEController) newSpecificEnvs(ddc *v1.DorisDisaggregated
 		corev1.EnvVar{Name: MS_ENDPOINT, Value: msEndpoint},
 		corev1.EnvVar{Name: CLUSTER_ID, Value: fmt.Sprintf("%d", ddc.GetInstanceHashId())},
 		corev1.EnvVar{Name: STATEFULSET_NAME, Value: stsName},
-		corev1.EnvVar{Name: resource.ENV_FE_ADDR, Value: ddc.GetFEServiceName()},
+		corev1.EnvVar{Name: resource.ENV_FE_ADDR, Value: ddc.GetFEVIPAddresss()},
 		corev1.EnvVar{Name: resource.ENV_FE_ELECT_NUMBER, Value: strconv.FormatInt(int64(ddc.GetElectionNumber()), 10)},
 	)
 	return feEnvs