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.
---