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 #5353: [FLINK-8503] [flip6] Display TaskExecutor logs and...
Date Wed, 31 Jan 2018 10:59:58 GMT
Github user tillrohrmann commented on a diff in the pull request:

    https://github.com/apache/flink/pull/5353#discussion_r165018462
  
    --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/taskexecutor/TaskExecutorGateway.java
---
    @@ -175,4 +177,13 @@
     		final AllocationID allocationId,
     		final Throwable cause,
     		@RpcTimeout final Time timeout);
    +
    +	/**
    +	 * Requests the file upload of the specified type to the cluster's {@link BlobServer}.
    +	 *
    +	 * @param fileType to upload
    +	 * @param timeout for the asynchronous operation
    +	 * @return Future which is completed with the {@link TransientBlobKey} of the uploaded
file.
    +	 */
    +	CompletableFuture<TransientBlobKey> requestFileUpload(FileType fileType, @RpcTimeout
Time timeout);
    --- End diff --
    
    Yes, we should adapt `RpcTaskManagerGateway` accordingly.


---

Mime
View raw message