diff --git a/test/e2e/apps/job.go b/test/e2e/apps/job.go index d10a444f07d..5255da7d295 100644 --- a/test/e2e/apps/job.go +++ b/test/e2e/apps/job.go @@ -174,7 +174,8 @@ var _ = SIGDescribe("Job", func() { It("should exceed backoffLimit", func() { By("Creating a job") - job := framework.NewTestJob("fail", "backofflimit", v1.RestartPolicyNever, 1, 1, nil, 0) + backoff := 1 + job := framework.NewTestJob("fail", "backofflimit", v1.RestartPolicyNever, 1, 1, nil, int32(backoff)) job, err := framework.CreateJob(f.ClientSet, f.Namespace.Name, job) Expect(err).NotTo(HaveOccurred()) By("Ensuring job exceed backofflimit") @@ -182,11 +183,12 @@ var _ = SIGDescribe("Job", func() { err = framework.WaitForJobFailure(f.ClientSet, f.Namespace.Name, job.Name, framework.JobTimeout, "BackoffLimitExceeded") Expect(err).NotTo(HaveOccurred()) - By("Checking that only one pod created and status is failed") + By(fmt.Sprintf("Checking that %d pod created and status is failed", backoff+1)) pods, err := framework.GetJobPods(f.ClientSet, f.Namespace.Name, job.Name) Expect(err).NotTo(HaveOccurred()) - Expect(pods.Items).To(HaveLen(1)) - pod := pods.Items[0] - Expect(pod.Status.Phase).To(Equal(v1.PodFailed)) + Expect(pods.Items).To(HaveLen(backoff + 1)) + for _, pod := range pods.Items { + Expect(pod.Status.Phase).To(Equal(v1.PodFailed)) + } }) })