Add event

hzxuzhonghu · hzxuzhonghu · commit 490ba7bded6f · 2019-08-19T17:37:21.000+08:00
diff --git a/pkg/controllers/job/job_controller.go b/pkg/controllers/job/job_controller.go
@@ -328,8 +328,9 @@ func (cc *Controller) processNextReq(count uint32) bool {
 			queue.AddRateLimited(req)
 			return true
 		}
-
-		glog.V(2).Infof("Dropping job<%s/%s> out of the queue: %v", jobInfo.Job.Namespace, jobInfo.Job.Name, err)
+		cc.recordJobEvent(jobInfo.Job.Namespace, jobInfo.Job.Name, vkbatchv1.ExecuteAction, fmt.Sprintf(
+			"Job failed on action %s for retry limit reached", action))
+		glog.Warningf("Dropping job<%s/%s> out of the queue: %v because max retries has reached", jobInfo.Job.Namespace, jobInfo.Job.Name, err)
 	}
 
 	// If no error, forget it.

Original file line number	Diff line number	Diff line change
`@@ -328,8 +328,9 @@ func (cc *Controller) processNextReq(count uint32) bool {`
`328`	`328`	`queue.AddRateLimited(req)`
`329`	`329`	`return true`
`330`	`330`	`}`
`331`		`-`
`332`		`- glog.V(2).Infof("Dropping job<%s/%s> out of the queue: %v", jobInfo.Job.Namespace, jobInfo.Job.Name, err)`
	`331`	`+ cc.recordJobEvent(jobInfo.Job.Namespace, jobInfo.Job.Name, vkbatchv1.ExecuteAction, fmt.Sprintf(`
	`332`	`+ "Job failed on action %s for retry limit reached", action))`
	`333`	`+ glog.Warningf("Dropping job<%s/%s> out of the queue: %v because max retries has reached", jobInfo.Job.Namespace, jobInfo.Job.Name, err)`
`333`	`334`	`}`
`334`	`335`
`335`	`336`	`// If no error, forget it.`