[FLINK-9872] SavepointITCase#testSavepointForJobWithIteration does not properly cancel jobs

• Type: Bug
• Status: Closed
• Priority: Minor
• Resolution: Fixed
• Affects Version/s: 1.5.1, 1.6.0
• Fix Version/s: 1.5.2, 1.6.0
• Component/s: Tests
• Assignee: Chesnay Schepler
• Reporter: Chesnay Schepler
• Created: 17/Jul/18 09:44
• Updated: 02/Oct/19 17:49
• Resolved: 19/Jul/18 06:41

Description

The SavepointITCase attempts to cancel a job by calling cancel on a source instance. However this instance isn't actually executed on the cluster, since it is serialized during the submission process.

 

Additionally we aren't waiting for the cancellation to finish, causing the test to log several exceptions when the cluster is shutdown.

Issue Links

• links to: GitHub Pull Request #6349