flink-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From tillrohrmann <...@git.apache.org>
Subject [GitHub] flink pull request #4728: [FLINK-7668] Add ExecutionGraphCache for Execution...
Date Wed, 27 Sep 2017 11:51:35 GMT
Github user tillrohrmann commented on a diff in the pull request:

    --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/webmonitor/RestfulGateway.java
    @@ -38,5 +44,36 @@
     	 * @param timeout for this operation
     	 * @return Future REST endpoint address
    -	CompletableFuture<String> requestRestAddress(Time timeout);
    +	CompletableFuture<String> requestRestAddress(@RpcTimeout  Time timeout);
    +	/**
    +	 * Requests the AccessExecutionGraph for the given jobId. If there is no such graph,
    +	 * the future is completed with a {@link JobNotFoundException}.
    +	 *
    +	 * @param jobId identifying the job whose AccessExecutionGraph is requested
    +	 * @param timeout for the asynchronous operation
    +	 * @return Future containing the AccessExecutionGraph for the given jobId, otherwise
{@link JobNotFoundException}
    +	 */
    +	CompletableFuture<AccessExecutionGraph> requestJob(JobID jobId, @RpcTimeout Time
    --- End diff --
    It makes sense to accumulate (all) methods required for the REST handlers in a common
interface because it will be implemented by the `Dispatcher` as well as the `JobMaster`. Right
now, the `RestfulInterface` is used two purposes: 1. retrieving the REST address and 2. all
REST handler related requests. Once all information which is required by the REST handlers
is serializable, we no longer have to redirect. Then we can drop the `requestRestAddress`
method. Then I would also rename this interface into something like `RestInformationGateway`.
Until then, I would like to keep it how it is.


View raw message