Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/6107#discussion_r193341492
--- Diff:
flink-java/src/main/java/org/apache/flink/api/java/ExecutionEnvironment.java ---
@@ -844,7 +844,7 @@ public JobExecutionResult execute() throws Exception {
/**
* Registers a file at the distributed cache under the given name. The
file will be accessible
* from any user-defined function in the (distributed) runtime under a
local path. Files
- * may be local files (as long as all relevant workers have access to
it), or files in a distributed file system.
+ * may be local files (which will be distributed viaBlobServer), or
files in a distributed file system.
--- End diff --
missing space after via (several instances)
---
