We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent c828f0c commit 6b215bfCopy full SHA for 6b215bf
integ/job_cancellation_test.go
@@ -163,11 +163,17 @@ func (s *IntegSuite) TestCancelledJobWithoutSavepoint(c *C) {
163
c.Assert(err, IsNil)
164
165
// wait a bit
166
- time.Sleep(1 * time.Second)
167
168
- job = s.Util.GetJobOverview(currApp)
169
- c.Assert(job["status"], Equals, "CANCELED")
+ counter := 0
+ for counter < 120 {
+ time.Sleep(1 * time.Second)
170
+
171
+ job = s.Util.GetJobOverview(currApp)
172
+ fmt.Sprintf("job status: %s", job["status"])
173
+ counter++
174
+ }
175
176
+ c.Assert(job["status"], Equals, "CANCELED")
177
newApp, err := s.Util.Update(config.Name, func(app *v1beta1.FlinkApplication) {
178
app.Spec.Image = NewImage
179
})
0 commit comments