From 84f05c3e1857a1fb396a80b1fa829bbfa4919635 Mon Sep 17 00:00:00 2001 From: Syulin7 <735122171@qq.com> Date: Sun, 15 Jan 2023 15:52:22 +0800 Subject: [PATCH 1/4] add MaxConcurrentReconciles to JobControllerConfiguration Signed-off-by: Syulin7 <735122171@qq.com> --- pkg/controller.v1/common/job_controller.go | 12 +++++++++++- 1 file changed, 11 insertions(+), 1 deletion(-) diff --git a/pkg/controller.v1/common/job_controller.go b/pkg/controller.v1/common/job_controller.go index 730b55f4..d6445f93 100644 --- a/pkg/controller.v1/common/job_controller.go +++ b/pkg/controller.v1/common/job_controller.go @@ -78,6 +78,10 @@ const ( type JobControllerConfiguration struct { // GangScheduling choice: None, volcano and scheduler-plugins GangScheduling GangScheduler + + // MaxConcurrentReconciles is the maximum number of concurrent Reconciles which can be run. + // Defaults to 1. + MaxConcurrentReconciles int } func (c *JobControllerConfiguration) EnableGangScheduling() bool { @@ -187,6 +191,7 @@ var GenNonGangSchedulerSetupFunc = func() GangSchedulingSetupFunc { func NewJobController( controllerImpl apiv1.ControllerInterface, reconcilerSyncPeriod metav1.Duration, + maxConcurrentReconciles int, kubeClientSet kubeclientset.Interface, setupPodGroup GangSchedulingSetupFunc, kubeInformerFactory kubeinformers.SharedInformerFactory, @@ -208,9 +213,14 @@ func NewJobController( Recorder: eventBroadcaster.NewRecorder(scheme.Scheme, corev1.EventSource{Component: controllerImpl.ControllerName()}), } + jobControllerConfig := JobControllerConfiguration{ + GangScheduling: GangSchedulerNone, + MaxConcurrentReconciles: maxConcurrentReconciles, + } + jc := JobController{ Controller: controllerImpl, - Config: JobControllerConfiguration{GangScheduling: GangSchedulerNone}, + Config: jobControllerConfig, PodControl: podControl, ServiceControl: serviceControl, KubeClientSet: kubeClientSet, From 4776ad4796886e0e11acea6dbf2fda18ab774aee Mon Sep 17 00:00:00 2001 From: Syulin7 <735122171@qq.com> Date: Mon, 16 Jan 2023 11:59:14 +0800 Subject: [PATCH 2/4] update License Signed-off-by: Syulin7 <735122171@qq.com> --- go.sum | 1 + 1 file changed, 1 insertion(+) diff --git a/go.sum b/go.sum index 6683e869..2e2a0fa9 100644 --- a/go.sum +++ b/go.sum @@ -888,6 +888,7 @@ k8s.io/component-base v0.25.0 h1:haVKlLkPCFZhkcqB6WCvpVxftrg6+FK5x1ZuaIDaQ5Y= k8s.io/component-base v0.25.0/go.mod h1:F2Sumv9CnbBlqrpdf7rKZTmmd2meJq0HizeyY/yAFxk= k8s.io/gengo v0.0.0-20200413195148-3a45101e95ac/go.mod h1:ezvh/TsK7cY6rbqRK0oQQ8IAqLxYwwyPxAX1Pzy0ii0= k8s.io/gengo v0.0.0-20200428234225-8167cfdcfc14/go.mod h1:ezvh/TsK7cY6rbqRK0oQQ8IAqLxYwwyPxAX1Pzy0ii0= +k8s.io/gengo v0.0.0-20211129171323-c02415ce4185 h1:TT1WdmqqXareKxZ/oNXEUSwKlLiHzPMyB0t8BaFeBYI= k8s.io/klog v1.0.0/go.mod h1:4Bi6QPql/J/LkTDqv7R/cd3hPo4k2DG6Ptcz060Ez5I= k8s.io/klog/v2 v2.0.0/go.mod h1:PBfzABfn139FHAV07az/IF9Wp1bkk3vpT2XSJ76fSDE= k8s.io/klog/v2 v2.2.0/go.mod h1:Od+F08eJP+W3HUb4pSrPpgp9DGU4GzlpG/TmITuYh/Y= From ff1fab8e89a9dadd7c45bfb5391a6d0c44fac8f9 Mon Sep 17 00:00:00 2001 From: Syulin7 <735122171@qq.com> Date: Wed, 18 Jan 2023 10:08:04 +0800 Subject: [PATCH 3/4] fix go mod Signed-off-by: Syulin7 <735122171@qq.com> --- go.sum | 1 - 1 file changed, 1 deletion(-) diff --git a/go.sum b/go.sum index 2e2a0fa9..6683e869 100644 --- a/go.sum +++ b/go.sum @@ -888,7 +888,6 @@ k8s.io/component-base v0.25.0 h1:haVKlLkPCFZhkcqB6WCvpVxftrg6+FK5x1ZuaIDaQ5Y= k8s.io/component-base v0.25.0/go.mod h1:F2Sumv9CnbBlqrpdf7rKZTmmd2meJq0HizeyY/yAFxk= k8s.io/gengo v0.0.0-20200413195148-3a45101e95ac/go.mod h1:ezvh/TsK7cY6rbqRK0oQQ8IAqLxYwwyPxAX1Pzy0ii0= k8s.io/gengo v0.0.0-20200428234225-8167cfdcfc14/go.mod h1:ezvh/TsK7cY6rbqRK0oQQ8IAqLxYwwyPxAX1Pzy0ii0= -k8s.io/gengo v0.0.0-20211129171323-c02415ce4185 h1:TT1WdmqqXareKxZ/oNXEUSwKlLiHzPMyB0t8BaFeBYI= k8s.io/klog v1.0.0/go.mod h1:4Bi6QPql/J/LkTDqv7R/cd3hPo4k2DG6Ptcz060Ez5I= k8s.io/klog/v2 v2.0.0/go.mod h1:PBfzABfn139FHAV07az/IF9Wp1bkk3vpT2XSJ76fSDE= k8s.io/klog/v2 v2.2.0/go.mod h1:Od+F08eJP+W3HUb4pSrPpgp9DGU4GzlpG/TmITuYh/Y= From 43d6a892e0264706149a6abdd1aaff77535c80f2 Mon Sep 17 00:00:00 2001 From: Syulin7 <735122171@qq.com> Date: Sat, 28 Jan 2023 10:27:46 +0800 Subject: [PATCH 4/4] fix go mod Signed-off-by: Syulin7 <735122171@qq.com> --- go.sum | 1 + 1 file changed, 1 insertion(+) diff --git a/go.sum b/go.sum index 6683e869..2e2a0fa9 100644 --- a/go.sum +++ b/go.sum @@ -888,6 +888,7 @@ k8s.io/component-base v0.25.0 h1:haVKlLkPCFZhkcqB6WCvpVxftrg6+FK5x1ZuaIDaQ5Y= k8s.io/component-base v0.25.0/go.mod h1:F2Sumv9CnbBlqrpdf7rKZTmmd2meJq0HizeyY/yAFxk= k8s.io/gengo v0.0.0-20200413195148-3a45101e95ac/go.mod h1:ezvh/TsK7cY6rbqRK0oQQ8IAqLxYwwyPxAX1Pzy0ii0= k8s.io/gengo v0.0.0-20200428234225-8167cfdcfc14/go.mod h1:ezvh/TsK7cY6rbqRK0oQQ8IAqLxYwwyPxAX1Pzy0ii0= +k8s.io/gengo v0.0.0-20211129171323-c02415ce4185 h1:TT1WdmqqXareKxZ/oNXEUSwKlLiHzPMyB0t8BaFeBYI= k8s.io/klog v1.0.0/go.mod h1:4Bi6QPql/J/LkTDqv7R/cd3hPo4k2DG6Ptcz060Ez5I= k8s.io/klog/v2 v2.0.0/go.mod h1:PBfzABfn139FHAV07az/IF9Wp1bkk3vpT2XSJ76fSDE= k8s.io/klog/v2 v2.2.0/go.mod h1:Od+F08eJP+W3HUb4pSrPpgp9DGU4GzlpG/TmITuYh/Y=