Github user tillrohrmann commented on a diff in the pull request:

    https://github.com/apache/flink/pull/5766#discussion_r177776345
  
    --- Diff: 
flink-runtime/src/main/java/org/apache/flink/runtime/minicluster/MiniCluster.java
 ---
    @@ -606,6 +632,28 @@ public JobExecutionResult executeJobBlocking(JobGraph 
job) throws JobExecutionEx
                // from the ResourceManager
                job.setAllowQueuedScheduling(true);
     
    +           CompletableFuture<Void> jarUploadFuture = 
currentDispatcherGateway.getBlobServerPort(rpcTimeout)
    --- End diff --
    
    This looks like duplicate code.


---

Reply via email to