fix(controller): Add scheduler name validation for StatefulSet podgro…

…up creation

Signed-off-by: liuqw <[email protected]>

pkg/controllers/podgroup/pg_controller_handler.go

@@ -19,6 +19,7 @@ package podgroup
 import (
 	"context"
 	"encoding/json"
+	"slices"
 	"strings"
 
 	appsv1 "k8s.io/api/apps/v1"
@@ -138,6 +139,10 @@ func (pg *pgcontroller) addStatefulSet(obj interface{}) {
 		if len(pods) > 0 {
 			pod := pods[0]
 			klog.V(4).Infof("Try to create podgroup for pod %s/%s", pod.Namespace, pod.Name)
+			if !slices.Contains(pg.schedulerNames, pod.Spec.SchedulerName) {
+				klog.V(4).Infof("Pod %s field SchedulerName is not matched", klog.KObj(pod))
+				return
+			}
 			err := pg.createNormalPodPGIfNotExist(pod)
 			if err != nil {
 				klog.Errorf("Failed to create PodGroup for pod <%s/%s>: %v", pod.Namespace, pod.Name, err)