From 7cbff93e0dda1df3af19f4ace7604219b1c82d8b Mon Sep 17 00:00:00 2001 From: Zexi Li Date: Wed, 28 Feb 2024 10:24:46 +0800 Subject: [PATCH] fix(scheduler): unsued key --- pkg/scheduler/manager/task_queue.go | 5 ++--- 1 file changed, 2 insertions(+), 3 deletions(-) diff --git a/pkg/scheduler/manager/task_queue.go b/pkg/scheduler/manager/task_queue.go index 1aec2c0162..58cfeac7bd 100644 --- a/pkg/scheduler/manager/task_queue.go +++ b/pkg/scheduler/manager/task_queue.go @@ -231,14 +231,13 @@ func (teqm *TaskExecutorQueueManager) GetQueue(schedType string) *TaskExecutorQu defer teqm.lock.Unlock() var ( - key string taskExecutorQueue *TaskExecutorQueue ok bool ) - if taskExecutorQueue, ok = teqm.taskExecutorMap[key]; !ok { + if taskExecutorQueue, ok = teqm.taskExecutorMap[schedType]; !ok { taskExecutorQueue = NewTaskExecutorQueue(schedType, teqm.stopCh) - teqm.taskExecutorMap[key] = taskExecutorQueue + teqm.taskExecutorMap[schedType] = taskExecutorQueue } return taskExecutorQueue