Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/6199#discussion_r197721680 --- Diff: flink-runtime-web/src/main/java/org/apache/flink/runtime/webmonitor/handlers/JarRunHandler.java --- @@ -114,17 +114,12 @@ public JarRunHandler( CompletableFuture<JobGraph> jarUploadFuture = jobGraphFuture.thenCombine(blobServerPortFuture, (jobGraph, blobServerPort) -> { final InetSocketAddress address = new InetSocketAddress(getDispatcherHost(gateway), blobServerPort); - final List<PermanentBlobKey> keys; - try { - keys = BlobClient.uploadFiles(address, configuration, jobGraph.getJobID(), jobGraph.getUserJars()); + try (BlobClient blobClient = new BlobClient(address, configuration)) { + ClientUtils.uploadAndSetUserJars(jobGraph, blobClient); --- End diff -- we _could_ use `uploadJobGraphFiles` here, but there isn't really a use-case for uploading distributed cache artifacts when going through the JarRunHandler, since we're already on the server here.
---