[FLINK-20020] Make UnsuccessfulExecutionException part of the JobClient.getJobExecutionResult() contract.

• Type: Improvement
• Status: Open
• Priority: Not a Priority
• Resolution: Unresolved
• Affects Version/s: 1.12.0
• Component/s: Client / Job Submission
• Labels: auto-deprioritized-major auto-deprioritized-minor auto-unassigned pull-request-available
• Assignee: Unassigned
• Reporter: Kostas Kloudas
• Created: 06/Nov/20 09:25
• Updated: 28/Jul/22 22:37

Description

Currently, different implementations of the JobClient throw different exceptions. The ClusterClientJobClientAdapter wraps the exception from the JobResult.toJobExecutionResult() into a ProgramInvocationException, the MiniClusterJobClient simply wraps it in a CompletionException and the EmbeddedJobClient wraps it into an UnsuccessfulExecutionException.

With this issue I would like to propose making the exception uniform and part of the contract and as a candidate I would propose the behaviour of the EmbeddedJobClient which throws an UnsuccessfulExecutionException. The reason is that this exception also includes the status of the application.

Issue Links

• links to: GitHub Pull Request #14028