This commit is contained in:
yarntime@163.com
2016-12-05 14:23:07 +08:00
parent 545f749a0d
commit 17e91695f9

View File

@@ -399,14 +399,14 @@ func (scaler *JobScaler) ScaleSimple(namespace, name string, preconditions *Scal
} }
parallelism := int32(newSize) parallelism := int32(newSize)
job.Spec.Parallelism = &parallelism job.Spec.Parallelism = &parallelism
udpatedJob, err := scaler.c.Jobs(namespace).Update(job) updatedJob, err := scaler.c.Jobs(namespace).Update(job)
if err != nil { if err != nil {
if errors.IsConflict(err) { if errors.IsConflict(err) {
return "", ScaleError{ScaleUpdateConflictFailure, job.ResourceVersion, err} return "", ScaleError{ScaleUpdateConflictFailure, job.ResourceVersion, err}
} }
return "", ScaleError{ScaleUpdateFailure, job.ResourceVersion, err} return "", ScaleError{ScaleUpdateFailure, job.ResourceVersion, err}
} }
return udpatedJob.ObjectMeta.ResourceVersion, nil return updatedJob.ObjectMeta.ResourceVersion, nil
} }
// Scale updates a Job to a new size, with optional precondition check (if preconditions is not nil), // Scale updates a Job to a new size, with optional precondition check (if preconditions is not nil),