Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/6147#discussion_r195047827
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/jobgraph/JobGraph.java ---
@@ -593,10 +596,37 @@ public void uploadUserArtifacts(InetSocketAddress
blobServerAddress, Configurati
new
DistributedCache.DistributedCacheEntry(
--- End diff --
Should we maybe distinguish between a `DistributedCacheEntry` which
represents an accessible file and a `BlobServerStoredDistributedCacheEntry`
which knows the `BlobKey` under which the file is stored. This would make the
whole upload and download business a bit clearer.
---
