Merge pull request #809 from hzxuzhonghu/sched

Prevent memory leak
kubernetes-retired · Apr 20, 2019 · 19f95af · 19f95af
2 parents 63b4dbc + fe71c70
commit 19f95af
Showing 1 changed file with 5 additions and 0 deletions.
diff --git a/pkg/scheduler/cache/cache.go b/pkg/scheduler/cache/cache.go
@@ -489,6 +489,8 @@ func (sc *SchedulerCache) processCleanupJob() {
 		return
 	}
 
+	defer sc.deletedJobs.Done(obj)
+
 	job, found := obj.(*kbapi.JobInfo)
 	if !found {
 		glog.Errorf("Failed to convert <%v> to *JobInfo", obj)
@@ -516,6 +518,9 @@ func (sc *SchedulerCache) processResyncTask() {
 	if shutdown {
 		return
 	}
+
+	defer sc.errTasks.Done(obj)
+
 	task, ok := obj.(*kbapi.TaskInfo)
 	if !ok {
 		glog.Errorf("failed to convert %v to *v1.Pod", obj)