chore: hostNetwork supports sharding (#8517)

controllers/apps/transformer_cluster_api_normalization.go

@@ -22,7 +22,9 @@ package apps
 import (
 	"fmt"
 	"maps"
+	"strings"
 
+	"golang.org/x/exp/slices"
 	apierrors "k8s.io/apimachinery/pkg/api/errors"
 	"k8s.io/apimachinery/pkg/types"
 	"k8s.io/apimachinery/pkg/util/sets"
@@ -217,6 +219,21 @@ func (t *ClusterAPINormalizationTransformer) buildCompAnnotationsInheritedFromCl
 	for _, compSpec := range transCtx.ComponentSpecs {
 		annotations[compSpec.Name] = maps.Clone(clusterAnnotations)
 	}
+
+	// covert the sharding hostNetwork annotation to the component annotation
+	hnShardingOrComps, ok := cluster.Annotations[constant.HostNetworkAnnotationKey]
+	if !ok {
+		return annotations
+	}
+
+	hnShardingOrCompList := strings.Split(hnShardingOrComps, ",")
+	for _, sharding := range cluster.Spec.ShardingSpecs {
+		if slices.Index(hnShardingOrCompList, sharding.Name) >= 0 {
+			for _, compSpec := range transCtx.ShardingComponentSpecs[sharding.Name] {
+				annotations[compSpec.Name][constant.HostNetworkAnnotationKey] = compSpec.Name
+			}
+		}
+	}
 	return annotations
 }
 

pkg/controller/component/utils.go

@@ -121,9 +121,6 @@ func hasHostNetworkCapability(synthesizedComp *SynthesizedComponent, compDef *ap
 }
 
 func hasHostNetworkEnabled(annotations map[string]string, compName string) bool {
-	if annotations == nil {
-		return false
-	}
 	comps, ok := annotations[constant.HostNetworkAnnotationKey]
 	if !ok {
 		return false