Merge pull request kubernetes-retired#558 from mateusz-ciesielski/master

Reduce verbosity level for recurring logs

Author: k8s-ci-robot

pkg/scheduler/actions/allocate/allocate.go

@@ -54,7 +54,7 @@ func (alloc *allocateAction) Execute(ssn *framework.Session) {
 			queues.Push(queue)
 		}
 
-		glog.V(3).Infof("Added Job <%s/%s> into Queue <%s>", job.Namespace, job.Name, job.Queue)
+		glog.V(4).Infof("Added Job <%s/%s> into Queue <%s>", job.Namespace, job.Name, job.Queue)
 		jobsMap[job.Queue].Push(job)
 	}
 
@@ -78,7 +78,7 @@ func (alloc *allocateAction) Execute(ssn *framework.Session) {
 		glog.V(3).Infof("Try to allocate resource to Jobs in Queue <%v>", queue.Name)
 
 		if !found || jobs.Empty() {
-			glog.V(3).Infof("Can not find jobs for queue %s.", queue.Name)
+			glog.V(4).Infof("Can not find jobs for queue %s.", queue.Name)
 			continue
 		}
 
@@ -88,7 +88,7 @@ func (alloc *allocateAction) Execute(ssn *framework.Session) {
 			for _, task := range job.TaskStatusIndex[api.Pending] {
 				// Skip BestEffort task in 'allocate' action.
 				if task.Resreq.IsEmpty() {
-					glog.V(3).Infof("Task <%v/%v> is BestEffort task, skip it.",
+					glog.V(4).Infof("Task <%v/%v> is BestEffort task, skip it.",
 						task.Namespace, task.Name)
 					continue
 				}

pkg/scheduler/actions/preempt/preempt.go

@@ -78,7 +78,7 @@ func (alloc *preemptAction) Execute(ssn *framework.Session) {
 
 			// If no preemptors, no preemption.
 			if preemptors == nil || preemptors.Empty() {
-				glog.V(3).Infof("No preemptors in Queue <%s>, break.", queue.Name)
+				glog.V(4).Infof("No preemptors in Queue <%s>, break.", queue.Name)
 				break
 			}
 

pkg/scheduler/actions/reclaim/reclaim.go

@@ -57,7 +57,7 @@ func (alloc *reclaimAction) Execute(ssn *framework.Session) {
 				job.Queue, job.Namespace, job.Name)
 			continue
 		} else {
-			glog.V(3).Infof("Added Queue <%s> for Job <%s/%s>",
+			glog.V(4).Infof("Added Queue <%s> for Job <%s/%s>",
 				queue.Name, job.Namespace, job.Name)
 			queues.Push(queue)
 		}

pkg/scheduler/cache/cache.go

@@ -560,7 +560,7 @@ func (sc *SchedulerCache) Snapshot() *kbapi.ClusterInfo {
 	for _, value := range sc.Jobs {
 		// If no scheduling spec, does not handle it.
 		if value.PodGroup == nil && value.PDB == nil {
-			glog.V(3).Infof("The scheduling spec of Job <%v:%s/%s> is nil, ignore it.",
+			glog.V(4).Infof("The scheduling spec of Job <%v:%s/%s> is nil, ignore it.",
 				value.UID, value.Namespace, value.Name)
 
 			// Also tracing the running task assigned by other scheduler.

pkg/scheduler/plugins/gang/gang.go

@@ -113,7 +113,7 @@ func (gp *gangPlugin) OnSessionOpen(ssn *framework.Session) {
 		lReady := jobReady(lv)
 		rReady := jobReady(rv)
 
-		glog.V(3).Infof("Gang JobOrderFn: <%v/%v> is ready: %t, <%v/%v> is ready: %t",
+		glog.V(4).Infof("Gang JobOrderFn: <%v/%v> is ready: %t, <%v/%v> is ready: %t",
 			lv.Namespace, lv.Name, lReady, rv.Namespace, rv.Name, rReady)
 
 		if lReady && rReady {