Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/4358#discussion_r142129292
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/blob/BlobClient.java ---
@@ -120,6 +125,76 @@ public BlobClient(InetSocketAddress serverAddress,
Configuration clientConfig) t
}
}
+ /**
+ * Downloads the given BLOB from the given server and stores its
contents to a (local) file.
+ *
+ * <p>Transient BLOB files are deleted after a successful copy of the
server's data into the
+ * given <tt>localJarFile</tt>.
+ *
+ * @param jobId
+ * job ID the BLOB belongs to or <tt>null</tt> if
job-unrelated
+ * @param blobKey
+ * BLOB key
+ * @param localJarFile
+ * the local file to write to
+ * @param serverAddress
+ * address of the server to download from
+ * @param blobClientConfig
+ * client configuration for the connection
+ * @param numFetchRetries
+ * number of retries before failing
+ *
+ * @throws IOException
+ * if an I/O error occurs during the download
+ */
+ static void downloadFromBlobServer(
+ @Nullable JobID jobId, BlobKey blobKey, File
localJarFile,
+ InetSocketAddress serverAddress, Configuration
blobClientConfig, int numFetchRetries)
--- End diff --
Wrapping the parameters could be one per line.
---
