[flink] 01/02: [hotfix] Remove @RpcTimeout from JobMaster.requestJobDetails.

[trohrmann]

This is an automated email from the ASF dual-hosted git repository.

trohrmann pushed a commit to branch release-1.5
in repository https://gitbox.apache.org/repos/asf/flink.git

commit 95b198d31cb6a84d69fd8d7f5854f5d7f766e7b0
Author: gyao <g...@data-artisans.com>
AuthorDate: Wed Aug 22 13:27:54 2018 +0200

    [hotfix] Remove @RpcTimeout from JobMaster.requestJobDetails.
---
 .../src/main/java/org/apache/flink/runtime/jobmaster/JobMaster.java    | 3 +--
 1 file changed, 1 insertion(+), 2 deletions(-)

diff --git 
a/flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/JobMaster.java 
b/flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/JobMaster.java
index 6caa301..8b34a78 100644
--- 
a/flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/JobMaster.java
+++ 
b/flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/JobMaster.java
@@ -94,7 +94,6 @@ import 
org.apache.flink.runtime.rest.handler.legacy.backpressure.OperatorBackPre
 import org.apache.flink.runtime.rpc.FatalErrorHandler;
 import org.apache.flink.runtime.rpc.FencedRpcEndpoint;
 import org.apache.flink.runtime.rpc.RpcService;
-import org.apache.flink.runtime.rpc.RpcTimeout;
 import org.apache.flink.runtime.rpc.akka.AkkaRpcServiceUtils;
 import org.apache.flink.runtime.state.KeyGroupRange;
 import org.apache.flink.runtime.taskexecutor.AccumulatorReport;
@@ -908,7 +907,7 @@ public class JobMaster extends 
FencedRpcEndpoint<JobMasterId> implements JobMast
        }
 
        @Override
-       public CompletableFuture<JobDetails> requestJobDetails(@RpcTimeout Time 
timeout) {
+       public CompletableFuture<JobDetails> requestJobDetails(Time timeout) {
                final ExecutionGraph currentExecutionGraph = executionGraph;
                return CompletableFuture.supplyAsync(() -> 
WebMonitorUtils.createDetailsForJob(currentExecutionGraph), 
scheduledExecutorService);
        }