Skip to content

Commit

Permalink
Fix panic issue with job taskMinAvailable clone
Browse files Browse the repository at this point in the history
  • Loading branch information
rt849122 committed Jul 30, 2023
1 parent 1665e6d commit 3b3d4f2
Showing 1 changed file with 4 additions and 1 deletion.
5 changes: 4 additions & 1 deletion pkg/scheduler/api/job_info.go
Expand Up @@ -574,7 +574,7 @@ func (ji *JobInfo) Clone() *JobInfo {
PodGroup: ji.PodGroup.Clone(),

TaskStatusIndex: map[TaskStatus]tasksMap{},
TaskMinAvailable: ji.TaskMinAvailable,
TaskMinAvailable: map[TaskID]int32{},
TaskMinAvailableTotal: ji.TaskMinAvailableTotal,
Tasks: tasksMap{},
Preemptable: ji.Preemptable,
Expand All @@ -584,6 +584,9 @@ func (ji *JobInfo) Clone() *JobInfo {

ji.CreationTimestamp.DeepCopyInto(&info.CreationTimestamp)

for task, minAvailable := range ji.TaskMinAvailable {
info.TaskMinAvailable[task] = minAvailable
}
for _, task := range ji.Tasks {
info.AddTaskInfo(task.Clone())
}
Expand Down

0 comments on commit 3b3d4f2

Please sign in to comment.