Github user GJL commented on a diff in the pull request: https://github.com/apache/flink/pull/5184#discussion_r157876793 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/webmonitor/RestfulGateway.java --- @@ -92,4 +94,42 @@ * @return Future containing the collection of instance ids and the corresponding metric query service path */ CompletableFuture<Collection<Tuple2<ResourceID, String>>> requestTaskManagerMetricQueryServicePaths(@RpcTimeout Time timeout); + + /** + * Returns the {@link SerializedJobExecutionResult} for a job, or in case the job failed, the + * failure cause. + * + * @param jobId ID of the job that we are interested in. + * @param timeout Timeout for the asynchronous operation. + * + * @see #isJobExecutionResultPresent(JobID, Time) + * + * @return {@link CompletableFuture} containing the {@link JobExecutionResult} or a + * {@link Throwable} which represents the failure cause. If there is no result, the future will + * be completed exceptionally with + * {@link org.apache.flink.runtime.messages.JobExecutionResultNotFoundException} + */ + default CompletableFuture<JobExecutionResult> getJobExecutionResult( + JobID jobId, + @RpcTimeout Time timeout) { + throw new UnsupportedOperationException(); + } + + /** + * Tests if the {@link SerializedJobExecutionResult} is present. --- End diff -- Javadoc needs to be updated.
---