Update RegisterMandatoryFitPredicate to avoid double register.

plugin/pkg/scheduler/algorithmprovider/defaults/defaults.go

@@ -176,7 +176,6 @@ func defaultPredicates() sets.String {
 		factory.RegisterFitPredicate("CheckNodeDiskPressure", predicates.CheckNodeDiskPressurePredicate),
 
 		// Fit is determied by node condtions: not ready, network unavailable and out of disk.
-		factory.RegisterFitPredicate("CheckNodeCondition", predicates.CheckNodeConditionPredicate),
 		factory.RegisterMandatoryFitPredicate("CheckNodeCondition", predicates.CheckNodeConditionPredicate),
 
 		// Fit is determined by volume zone requirements.

plugin/pkg/scheduler/factory/plugins.go

@@ -72,10 +72,10 @@ var (
 	schedulerFactoryMutex sync.Mutex
 
 	// maps that hold registered algorithm types
-	fitPredicateMap          = make(map[string]FitPredicateFactory)
-	mandatoryFitPredicateMap = make(map[string]FitPredicateFactory)
-	priorityFunctionMap      = make(map[string]PriorityConfigFactory)
-	algorithmProviderMap     = make(map[string]AlgorithmProviderConfig)
+	fitPredicateMap        = make(map[string]FitPredicateFactory)
+	mandatoryFitPredicates = make(map[string]bool)
+	priorityFunctionMap    = make(map[string]PriorityConfigFactory)
+	algorithmProviderMap   = make(map[string]AlgorithmProviderConfig)
 
 	// Registered metadata producers
 	priorityMetadataProducer  MetadataProducerFactory
@@ -107,7 +107,8 @@ func RegisterMandatoryFitPredicate(name string, predicate algorithm.FitPredicate
 	schedulerFactoryMutex.Lock()
 	defer schedulerFactoryMutex.Unlock()
 	validateAlgorithmNameOrDie(name)
-	mandatoryFitPredicateMap[name] = func(PluginFactoryArgs) algorithm.FitPredicate { return predicate }
+	fitPredicateMap[name] = func(PluginFactoryArgs) algorithm.FitPredicate { return predicate }
+	mandatoryFitPredicates[name] = true
 	return name
 }
 
@@ -321,10 +322,12 @@ func getFitPredicateFunctions(names sets.String, args PluginFactoryArgs) (map[st
 		predicates[name] = factory(args)
 	}
 
-	// Always include required fit predicates.
-	for name, factory := range mandatoryFitPredicateMap {
-		if _, found := predicates[name]; !found {
-			predicates[name] = factory(args)
+	// Always include mandatory fit predicates.
+	for name, mandatory := range mandatoryFitPredicates {
+		if mandatory {
+			if factory, found := fitPredicateMap[name]; found {
+				predicates[name] = factory(args)
+			}
 		}
 	}