[FLINK-15116] Make JobClient stateless, remove AutoCloseable

• Type: Sub-task
• Status: Closed
• Priority: Major
• Resolution: Fixed
• Fix Version/s: 1.10.0
• Component/s: API / DataSet, API / DataStream
• Labels: pull-request-available
• Assignee: Aljoscha Krettek
• Reporter: Aljoscha Krettek
• Created: 06/Dec/19 18:17
• Updated: 14/Aug/20 11:48
• Resolved: 08/Dec/19 15:13

Description

Currently, JobClient is AutoCloseable and we require users to close the JobClient that they get as a result from executeAsync(). This is problematic because users can simply ignore the result of executeAsync() and then we will leak the resources that the client has.

We should change the JobClient so that it acquires the required ClusterClient for each method call and closes it again.

This means that the users no longer have the burden of managing the JobClient lifecycle, i.e. they can freely ignore the result of executeAsync().

Issue Links

• causes: FLINK-18959 Fail to archiveExecutionGraph because job is not finished when dispatcher close
• causes: FLINK-16637 Flink per job mode terminates before serving job cancellation result
• is related to: FLINK-14992 Add job submission listener to execution environments
• links to: GitHub Pull Request #10474