From e34fd7b6e6ef69042ec87495b85a92bea57be1d4 Mon Sep 17 00:00:00 2001 From: xuzhonghu Date: Sat, 20 Apr 2019 14:05:18 +0800 Subject: [PATCH] Prevent memory leak --- pkg/scheduler/cache/cache.go | 5 +++++ 1 file changed, 5 insertions(+) diff --git a/pkg/scheduler/cache/cache.go b/pkg/scheduler/cache/cache.go index 4d447ac2a..098b44e57 100644 --- 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)