reduce noisy log line and add pod information to event

pkg/controllers/job/job_controller.go

@@ -385,7 +385,7 @@ func (cc *jobcontroller) processNextReq(count uint32) bool {
 
 	if delayAct.action != busv1alpha1.SyncJobAction {
 		cc.recordJobEvent(jobInfo.Job.Namespace, jobInfo.Job.Name, batchv1alpha1.ExecuteAction, fmt.Sprintf(
-			"Start to execute action %s ", delayAct.action))
+			"Start to execute action %s due to pod %s", delayAct.action, req.PodName))
 	}
 
 	action := GetStateAction(delayAct)

pkg/scheduler/actions/allocate/allocate.go

@@ -143,7 +143,7 @@ func (alloc *Action) allocateResources(queues *util.PriorityQueue, jobsMap map[a
 			continue
 		}
 
-		klog.V(3).Infof("Try to allocate resource to Jobs in Queue <%s>", queue.Name)
+		klog.V(4).Infof("Try to allocate resource to Jobs in Queue <%s>", queue.Name)
 
 		jobs, found := jobsMap[queue.UID]
 		if !found || jobs.Empty() {

pkg/scheduler/framework/statement.go

@@ -287,7 +287,7 @@ func (s *Statement) Allocate(task *api.TaskInfo, nodeInfo *api.NodeInfo) (err er
 				task.Namespace, task.Name, hostname, s.ssn.UID, err)
 			errInfos = append(errInfos, err)
 		}
-		klog.V(3).Infof("After allocated Task <%v/%v> to Node <%v>: idle <%v>, used <%v>, releasing <%v>",
+		klog.V(4).Infof("After allocated Task <%v/%v> to Node <%v>: idle <%v>, used <%v>, releasing <%v>",
 			task.Namespace, task.Name, node.Name, node.Idle, node.Used, node.Releasing)
 	} else {
 		err := fmt.Errorf("Failed to find Node <%s> in Session <%s> index when allocating.",

pkg/scheduler/plugins/predicates/predicates.go

@@ -439,7 +439,7 @@ func (pp *predicatesPlugin) OnSessionOpen(ssn *framework.Session) {
 		// If the filtering logic is added to the Prefile node in the Volumebinding package in the future,
 		// the processing logic needs to be added to the return value result.
 		if predicate.podAffinityEnable {
-			klog.Infof("Executing podAffinityFilter PreFilter for task %s/%s", task.Namespace, task.Name)
+			klog.V(4).Infof("Executing podAffinityFilter PreFilter for task %s/%s", task.Namespace, task.Name)
 			_, status := podAffinityFilter.PreFilter(context.TODO(), state, task.Pod)
 			if err := handleSkipPrePredicatePlugin(status, state, task, interpodaffinity.Name); err != nil {
 				return err

pkg/scheduler/util/predicate_helper.go

@@ -94,7 +94,7 @@ func (ph *predicateHelper) PredicateNodes(task *api.TaskInfo, nodes []*api.NodeI
 
 		// TODO (k82cn): Enable eCache for performance improvement.
 		if err := fn(task, node); err != nil {
-			klog.V(3).Infof("Predicates failed: %v", err)
+			klog.V(4).Infof("Predicates failed: %v", err)
 			errorLock.Lock()
 			nodeErrorCache[node.Name] = err
 			ph.taskPredicateErrorCache[taskGroupid] = nodeErrorCache