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

    https://github.com/apache/flink/pull/5766#discussion_r177776420
  
    --- Diff: 
flink-runtime/src/main/java/org/apache/flink/runtime/minicluster/MiniCluster.java
 ---
    @@ -572,6 +576,28 @@ public void runDetached(JobGraph job) throws 
JobExecutionException, InterruptedE
                // from the ResourceManager
                job.setAllowQueuedScheduling(true);
     
    +           CompletableFuture<Void> jarUploadFuture = 
currentDispatcherGateway.getBlobServerPort(rpcTimeout)
    --- End diff --
    
    We could check whether we actually have something to upload or not.


---

Reply via email to