Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/4358#discussion_r137262572 --- Diff: flink-runtime-web/src/main/java/org/apache/flink/runtime/webmonitor/handlers/TaskManagerLogHandler.java --- @@ -158,7 +151,7 @@ protected void respondAsLeader(final ChannelHandlerContext ctx, final Routed rou cache = blobPortFuture.thenApplyAsync( (Integer port) -> { try { - return new BlobCache(new InetSocketAddress(jobManagerGateway.getHostname(), port), config, blobView); + return new TransientBlobCache(new InetSocketAddress(jobManagerGateway.getHostname(), port), config); } catch (IOException e) { throw new FlinkFutureException("Could not create BlobCache.", e); --- End diff -- Maybe we could adapt the exception message to `TransientBlobCache`.
---