diff --git a/cluster/plan.go b/cluster/plan.go index d656f27c..5bdbb083 100644 --- a/cluster/plan.go +++ b/cluster/plan.go @@ -810,17 +810,6 @@ func (c *Cluster) BuildSchedulerProcess(host *hosts.Host, serviceOptions v3.Kube fmt.Sprintf("%s:/etc/kubernetes:z", path.Join(host.PrefixPath, "/etc/kubernetes")), } - for arg, value := range c.Services.Scheduler.ExtraArgs { - if _, ok := c.Services.Scheduler.ExtraArgs[arg]; ok { - CommandArgs[arg] = value - } - } - - for arg, value := range CommandArgs { - cmd := fmt.Sprintf("--%s=%s", arg, value) - Command = append(Command, cmd) - } - matchedRange, err := util.SemVerMatchRange(c.Version, util.SemVerK8sVersion122OrHigher) if err != nil { logrus.Debugf("Error while matching cluster version [%s] with range [%s]", c.Version, util.SemVerK8sVersion122OrHigher) @@ -832,6 +821,17 @@ func (c *Cluster) BuildSchedulerProcess(host *hosts.Host, serviceOptions v3.Kube CommandArgs["authorization-kubeconfig"] = CommandArgs["kubeconfig"] } + for arg, value := range c.Services.Scheduler.ExtraArgs { + if _, ok := c.Services.Scheduler.ExtraArgs[arg]; ok { + CommandArgs[arg] = value + } + } + + for arg, value := range CommandArgs { + cmd := fmt.Sprintf("--%s=%s", arg, value) + Command = append(Command, cmd) + } + Binds = append(Binds, c.Services.Scheduler.ExtraBinds...) maxK8s122Version, err := util.StrToSemVer(MaxK8s122Version)